From 3bc6ed6a460896786dd16fcaecf2250bb4edece5 Mon Sep 17 00:00:00 2001
From: Amogh Desai <amoghrajesh1999@gmail.com>
Date: Mon, 2 Jun 2025 13:28:52 +0530
Subject: [PATCH] Log fallback to None when no XCom value is found

---
 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 b8b301e1511d9..0c330652956f2 100644
--- a/task-sdk/src/airflow/sdk/bases/xcom.py
+++ b/task-sdk/src/airflow/sdk/bases/xcom.py
@@ -264,6 +264,14 @@ def get_one(
 
         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