(airflow) branch main updated: Fix clearing of mapped task run (#48655)

[we...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

weilee 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 55546c3a0a9 Fix clearing of mapped task run (#48655)
55546c3a0a9 is described below

commit 55546c3a0a9ee656821f41c2bbb656e988eb7d33
Author: Daniel Standish <15...@users.noreply.github.com>
AuthorDate: Tue Apr 1 21:59:51 2025 -0700

    Fix clearing of mapped task run (#48655)
---
 airflow-core/src/airflow/api_fastapi/execution_api/routes/xcoms.py | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/airflow-core/src/airflow/api_fastapi/execution_api/routes/xcoms.py b/airflow-core/src/airflow/api_fastapi/execution_api/routes/xcoms.py
index 2f28acc4bc1..96483e4f08d 100644
--- a/airflow-core/src/airflow/api_fastapi/execution_api/routes/xcoms.py
+++ b/airflow-core/src/airflow/api_fastapi/execution_api/routes/xcoms.py
@@ -237,7 +237,7 @@ def set_xcom(
                     "message": "pushed value is too large to map as a downstream's dependency",
                 },
             )
-        session.add(task_map)
+        session.merge(task_map)
 
     # else:
     # TODO: Can/should we check if a client _hasn't_ provided this for an upstream of a mapped task? That