Log URL redirecting to No XCom error #44337
Description
Apache Airflow version
Other Airflow 2 version (please specify below)
If "Other Airflow 2 version" selected, which one?
2.10.1
What happened?
The Log URL (ti.log_url) from the triggered retry email doesn't redirect to the Logs when clicked but instead shows 'No XCom' as the error in the Airflow UI. The Logs are shown when a time in future is selected as the base_date in the UI.
Before changing the base_date in the UI,
After adding 1 second to the base_date in UI,
What you think should happen instead?
I think the issue might be due to milli seconds getting truncated which causes the difference between the execution datetime (untruncated) and the execution datetime rendered - base_date (truncated) in the ti.log_url
How to reproduce
Here is the DAG to reproduce the issue,
from airflow.decorators import dag, task
from datetime import datetime, timedelta
@dag(
dag_id='default_email_on_retry_example',
schedule_interval='@once',
start_date=datetime(2023, 1, 1),
catchup=False,
default_args={
'email': ['your@email.com'],
'email_on_retry': True,
'email_on_failure': False,
},
)
def default_email_on_retry_dag():
@task
def success_task():
print("This task will always succeed!")
@task(task_id='retry_task', retries=3, retry_delay=timedelta(seconds=15))
def retry_task():
print("This task will retry and fail.")
raise Exception("Simulated task failure for retry.")
success = success_task()
retry = retry_task()
success >> retry
default_email_on_retry_dag()
Click the Log Link from the email triggered by the DAG
Operating System
Linux
Versions of Apache Airflow Providers
No response
Deployment
Amazon (AWS) MWAA
Deployment details
No response
Anything else?
No response
Are you willing to submit PR?
- Yes I am willing to submit a PR!
Code of Conduct
- I agree to follow this project's Code of Conduct