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