Jorricks opened a new pull request #19353: URL: https://github.com/apache/airflow/pull/19353
When a DAG has been running for a bit, it often occurs in our workflow that a task is added. Often, people want to run these tasks for historical dates. However, when there are more TaskInstances you want to run than the `max_active_runs` DagRuns, you might cross the limit. Therefore, I felt we should add the option to mark the DagRun immediately as Queued. For now, the work around I did was mark the tasks I wanted to run as success first, then clear them. This yields the same result but requires more click, and Airflow is of course all about efficiency :) Love to hear some feedback on what you think about what I've done with the refactoring. In particulair: - Added the typing information to all args/kwargs - Instead of providing session with None, we use the asterix (*) to indicate it's a keyword and give it correct typing info. - Instead of repeating ourselves, I extracted a function that we can use for Queued and Running DagRun state changes. -- 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]
