AutomationDev85 opened a new pull request, #44916: URL: https://github.com/apache/airflow/pull/44916
# Description In multi scheduler deployment the Edge_Job table an executor self.running (contains the running task_instance keys which were scheduled by the scheduler) running out of sync. This PR adds a sync for the running. First it detect the jobs which are in the self.running but removed in the table. Then it removed this jobs from the running. After that the self.runnig contains only the job with were run by the executor and available in the DB. # Details about changes * Sync self.running with the edge_job table -- 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]
