From f8a1b85c648677ae0578654b7307a23a877963f5 Mon Sep 17 00:00:00 2001 From: Amogh Desai Date: Wed, 11 Jun 2025 14:58:20 +0530 Subject: [PATCH] [v3-0-test] Rename `len` in GetXComCount processing to `xcom_count` (#51611) (cherry picked from commit db435f75d20de786513746de95ade4863bcb1685) Co-authored-by: Amogh Desai --- task-sdk/src/airflow/sdk/execution_time/supervisor.py | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/task-sdk/src/airflow/sdk/execution_time/supervisor.py b/task-sdk/src/airflow/sdk/execution_time/supervisor.py index b2dd76d85b100..0471eb1f37dff 100644 --- a/task-sdk/src/airflow/sdk/execution_time/supervisor.py +++ b/task-sdk/src/airflow/sdk/execution_time/supervisor.py @@ -1054,8 +1054,8 @@ def _handle_request(self, msg: ToSupervisor, log: FilteringBoundLogger): xcom_result = XComResult.from_xcom_response(xcom) resp = xcom_result elif isinstance(msg, GetXComCount): - len = self.client.xcoms.head(msg.dag_id, msg.run_id, msg.task_id, msg.key) - resp = XComCountResponse(len=len) + xcom_count = self.client.xcoms.head(msg.dag_id, msg.run_id, msg.task_id, msg.key) + resp = XComCountResponse(len=xcom_count) elif isinstance(msg, GetXComSequenceItem): xcom = self.client.xcoms.get_sequence_item( msg.dag_id, msg.run_id, msg.task_id, msg.key, msg.offset