ephraimbuddy commented on issue #14205: URL: https://github.com/apache/airflow/issues/14205#issuecomment-910038834
I have made a PR related to this issue, see https://github.com/apache/airflow/pull/17945 What happens is that the method `DagRun.next_dagruns_to_examine` gets the earliest dagruns without considering the dag that has the dagrun. For example: If you have a dag with execution_date 2020,1,1 and set catchup=True, max_active_runs=1, schedule_interval='@daily' and another dag with execution_date 2021,1,1 and also set catchup=True, schedule_interval='@daily'. When you unpause the two dags, the dagruns would be created but only one dagrun would be active because of how `DagRun.next_dagruns_to_examine` works. I'm hopeful my PR would resolve this issue but I'm worried about performance. Please take a look: https://github.com/apache/airflow/pull/17945 @uranusjr @kaxil @ash -- 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]
