uranusjr opened a new pull request, #24971: URL: https://github.com/apache/airflow/pull/24971
First part toward #24489. To support list-of-dicts task-mapping (expand_kwargs), we need different logic in many places of task-mapping to handle the two difference "shapes" of data. Instead of putting conditionals everywhere, we should use polymorphism to switch between different implementations. This PR lays the foundation to this. A new class DictOfListsExpandInput is added to wrap kwargs received from expand(), and related logic is moved from MappedOperator to that class. It should be quite obvious in various places that I'm "leaving room" for something else; if you feel some abstraction is unnecessary (it's probably not), check #24838 to make sure. I also included some trivial annotation and code formatting stuffs here since they don't warrant a separate PR and fit as well here as anywhere else. -- 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]
