This is an automated email from the ASF dual-hosted git repository.
kaxilnaik pushed a commit to branch v3-0-test
in repository https://gitbox.apache.org/repos/asf/airflow.git
The following commit(s) were added to refs/heads/v3-0-test by this push:
new e9e185b2a75 [v3-0-test] Rename `len` in GetXComCount processing to
`xcom_count` (#51611) (#51612)
e9e185b2a75 is described below
commit e9e185b2a75b39ec4b0e2ad7f2ce06385e1e12ac
Author: github-actions[bot]
<41898282+github-actions[bot]@users.noreply.github.com>
AuthorDate: Thu Jun 12 20:43:18 2025 +0530
[v3-0-test] Rename `len` in GetXComCount processing to `xcom_count`
(#51611) (#51612)
(cherry picked from commit db435f75d20de786513746de95ade4863bcb1685)
Co-authored-by: Amogh Desai <[email protected]>
---
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 f3cc633fb63..4c3ed654ec1 100644
--- a/task-sdk/src/airflow/sdk/execution_time/supervisor.py
+++ b/task-sdk/src/airflow/sdk/execution_time/supervisor.py
@@ -1055,8 +1055,8 @@ class ActivitySubprocess(WatchedSubprocess):
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
