uranusjr opened a new pull request, #30641: URL: https://github.com/apache/airflow/pull/30641
An XComArg's `get_task_map_length()` should only return an integer when the *entire* task has finished. However, before this patch, it may attempt to count a mapped upstream even when some (or all!) of its expanded tis are still unfinished, resulting its downstream to be expanded prematurely. This patch adds an additional check before we count upstream results to ensure all the upstreams are actually finished. Fix #28973. One thing I don’t like in this patch is it adds an additional SQL query for each resolution. I have a hunch the two queries can be combined, but I’m not sure how. -- 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]
