This is an automated email from the ASF dual-hosted git repository.
amoghdesai pushed a commit to branch v3-0-test
in repository https://gitbox.apache.org/repos/asf/airflow.git
The following commit(s) were added to refs/heads/v3-0-test by this push:
new 9bd5f3f120d [v3-0-test] Log fallback to None when no XCom value is
found (#51285) (#51291)
9bd5f3f120d is described below
commit 9bd5f3f120d6647749799003651aa575d468e9d7
Author: github-actions[bot]
<41898282+github-actions[bot]@users.noreply.github.com>
AuthorDate: Mon Jun 2 17:45:50 2025 +0530
[v3-0-test] Log fallback to None when no XCom value is found (#51285)
(#51291)
(cherry picked from commit 807ba69ad3c8e2e5552b2fa840a1f9b47bfd8318)
Co-authored-by: Amogh Desai <[email protected]>
---
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
