potiuk commented on issue #29084: URL: https://github.com/apache/airflow/issues/29084#issuecomment-1435666446
I see the need, but I think having a parameter for that in in DAG is not the best way of doing it. For me it should be strictly dynamic task mapping parameter and more than that - you should be able to configure it separately for each dynamic task mapping. Why not something like that: ``` task.expand(x=[2, 4, 8], y=[5, 10]).max_active_tasks(30) ``` Sounds much more in-line with task flow/functional approach. -- 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]
