From 5a98f9ecbd5069bf6184624dc52053ee72552b7f Mon Sep 17 00:00:00 2001 From: Ash Berlin-Taylor Date: Thu, 1 Aug 2019 13:11:22 +0100 Subject: [PATCH] [AIRFLOW-4883] Bug-fix to killing hung file processes (#5706) PRs #5615 and #5605 and fought a bit over this change, and this is hard (but not impossible) to test so we didn't notice. (cherry picked from commit 3e3c0cd67272f9a400415cff7691218a80ff97aa) --- airflow/jobs/scheduler_job.py | 1 - 1 file changed, 1 deletion(-) diff --git a/airflow/jobs/scheduler_job.py b/airflow/jobs/scheduler_job.py index 7ddd3d96fd125..31bf3546c2db4 100644 --- a/airflow/jobs/scheduler_job.py +++ b/airflow/jobs/scheduler_job.py @@ -191,7 +191,6 @@ def kill(self): # The queue will likely get corrupted, so remove the reference self._result_queue = None self._kill_process() - self._manager.shutdown() def terminate(self, sigkill=False): """