AutomationDev85 opened a new pull request, #30699: URL: https://github.com/apache/airflow/pull/30699
Hi airflow community, this is my first PR and be happy to work on the scheduler runtime. We faced an issue with slow scheduler execution time by having millions of queued dag_runs for one DAG. This is the first PR and more is in the queue. This PR will add .all() to query to match the pydantic definition of function and return only list of dag_runs. This optimize the scheduler runtime because without this change the query is executed 2 times in function _start_queued_dagruns in airflow/jobs/scheduler_job_runner.py. So this saves execution time in the scheduler. -- 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]
