amoghrajesh commented on code in PR #47944:
URL: https://github.com/apache/airflow/pull/47944#discussion_r2002969562
##########
task-sdk/src/airflow/sdk/execution_time/xcom.py:
##########
@@ -40,6 +40,7 @@ def set(
task_id: str,
run_id: str,
map_index: int = -1,
+ mapped_length: int | None = None,
Review Comment:
Valid call, i checked that comment out. The other option I can think of is
calling the API directly for the case when mapped length is set? And not
including it here? WDYT about that?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
