amoskaliov commented on issue #53593:
URL: https://github.com/apache/airflow/issues/53593#issuecomment-3103552662
I confirm this bug appeared in 3.0.3. There wasn't in 3.0.2.
Here is the basic example:
```python
from datetime import datetime, timedelta
from airflow.sdk import dag, task
@dag(
schedule=timedelta(seconds=60),
start_date=datetime(2025, 7, 22),
catchup=False,
max_active_runs=1
)
def xcom_test():
@task
def xcom_task(ti):
data_xcom = ti.xcom_pull(key=f"test_key", include_prior_dates=True)
if data_xcom:
print(f'XCom pulled. Value: {data_xcom}')
else:
print(f'XCom not found')
ti.xcom_push(key=f"test_key", value=' - xcom value - ')
xcom_task()
xcom_test()
```
During the 2nd run you'll get `XCom not found`, although it was pushed
during the 1st run.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
