improve(xcom): validate key in XCom.set() to prevent empty strings

apache · Feb 20, 2025 · 29ad7c4 · 29ad7c4
1 parent b95990b
commit 29ad7c4
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/airflow/models/xcom.py b/airflow/models/xcom.py
@@ -154,6 +154,9 @@ def set(
         """
         from airflow.models.dagrun import DagRun
 
+        if not key:
+            raise ValueError(f"XCom key must be a non-empty string. Received: {key}")
+
         if not run_id:
             raise ValueError(f"run_id must be passed. Passed run_id={run_id}")