This is an automated email from the ASF dual-hosted git repository.
henry3260 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 dffc5079dde Remove stale TODO comments for XCom map_index handling
(#69369)
dffc5079dde is described below
commit dffc5079dde9d7170ebdae9c21893a92f49a2a2f
Author: fat-catTW <[email protected]>
AuthorDate: Sun Jul 5 23:43:11 2026 +0800
Remove stale TODO comments for XCom map_index handling (#69369)
* Remove stale XCom map_index TODOs
* Remove stale XCom map_index TODOs
---
task-sdk/src/airflow/sdk/api/client.py | 4 ----
1 file changed, 4 deletions(-)
diff --git a/task-sdk/src/airflow/sdk/api/client.py
b/task-sdk/src/airflow/sdk/api/client.py
index 037ddd7eb5f..55668c9f3bd 100644
--- a/task-sdk/src/airflow/sdk/api/client.py
+++ b/task-sdk/src/airflow/sdk/api/client.py
@@ -581,8 +581,6 @@ class XComOperations:
include_prior_dates: bool = False,
) -> XComResponse:
"""Get a XCom value from the API server."""
- # TODO: check if we need to use map_index as params in the uri
- # ref:
https://github.com/apache/airflow/blob/v2-10-stable/airflow/api_connexion/openapi/v1.yaml#L1785C1-L1785C81
params = {}
if map_index is not None and map_index >= 0:
params.update({"map_index": map_index})
@@ -622,8 +620,6 @@ class XComOperations:
mapped_length: int | None = None,
) -> OKResponse:
"""Set a XCom value via the API server."""
- # TODO: check if we need to use map_index as params in the uri
- # ref:
https://github.com/apache/airflow/blob/v2-10-stable/airflow/api_connexion/openapi/v1.yaml#L1785C1-L1785C81
params: dict[str, Any] = {}
if dag_result:
params["dag_result"] = dag_result
