This is an automated email from the ASF dual-hosted git repository.
amoghdesai pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/airflow.git
The following commit(s) were added to refs/heads/main by this push:
new 807ba69ad3c Log fallback to None when no XCom value is found (#51285)
807ba69ad3c is described below
commit 807ba69ad3c8e2e5552b2fa840a1f9b47bfd8318
Author: Amogh Desai <[email protected]>
AuthorDate: Mon Jun 2 15:09:58 2025 +0530
Log fallback to None when no XCom value is found (#51285)
---
task-sdk/src/airflow/sdk/bases/xcom.py | 8 ++++++++
1 file changed, 8 insertions(+)
diff --git a/task-sdk/src/airflow/sdk/bases/xcom.py
b/task-sdk/src/airflow/sdk/bases/xcom.py
index b8b301e1511..0c330652956 100644
--- a/task-sdk/src/airflow/sdk/bases/xcom.py
+++ b/task-sdk/src/airflow/sdk/bases/xcom.py
@@ -264,6 +264,14 @@ class BaseXCom:
if msg.value is not None:
return cls.deserialize_value(msg)
+ log.warning(
+ "No XCom value found; defaulting to None.",
+ key=key,
+ dag_id=dag_id,
+ task_id=task_id,
+ run_id=run_id,
+ map_index=map_index,
+ )
return None
@staticmethod
