The GitHub Actions job "Tests (AMD)" on airflow.git/feature/go-sdk/taskflow-arg-binding has failed. Run started by GitHub user jason810496 (triggered by jason810496).
Head commit for run: 25e2d12267b0213338a0eae3105b5f146d2e1356 / LIU ZHE YOU <[email protected]> Record mapped_length for Go stub tasks feeding dynamic task mapping A Go stub task whose list output a downstream .expand() maps over never recorded a TaskMap, because a foreign runtime cannot inspect the Dag to know its return value feeds a mapping and so never reported a mapped_length. Without it the scheduler could not determine the expansion size and left the mapped task upstream_failed. The execution API now flags such a stub task via a new TIRunContext.has_mapped_dependants field (derived from the serialized Dag, mirroring the Python task runner's iter_mapped_dependants check and its not-is_mapped guard). When set, the supervisor records the mapped_length of the runtime's mappable return value on its behalf -- the foreign-runtime analogue of the task runner's _push_xcom_if_needed. Regenerates the task-sdk datamodels, supervisor schema snapshot, Go models, and the ts-sdk supervisor schema. Report URL: https://github.com/apache/airflow/actions/runs/30193578130 With regards, GitHub Actions via GitBox --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
