uranusjr opened a new pull request #21635: URL: https://github.com/apache/airflow/pull/21635
This rewrites `expand_mapped_task()` to inspect `mapped_kwargs` and make itself useful for mapping against literals (which are not recorded in `TaskMap`), and should work for things like `map(a=upstream_a(), b=upstream_b())` (assuming it is correctly called when both upstreams finish—this is not the case now, we need to fix that later). I think the logic is still not quite right (e.g. mapping against a *mapped* upstream), but this new logic should be useful for what we're going to need to fix. -- 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]
