[AIRFLOW-6910] Fix kill_zombie method call (apache#7531)

FlyrInc · Mar 5, 2020 · 2001ed6 · 2001ed6
1 parent 580a7f5
commit 2001ed6
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/airflow/jobs/scheduler_job.py b/airflow/jobs/scheduler_job.py
@@ -741,7 +741,7 @@ def kill_zombies(self, dagbag, zombies, session=None):
         had a heartbeat for too long, in the current DagBag.
 
         :param zombies: zombie task instances to kill.
-        :type zombies: List[airflow.models.taskinstance.SimpleyTaskInstance]
+        :type zombies: List[airflow.models.taskinstance.SimpleTaskInstance]
         :param session: DB session.
         """
         TI = models.TaskInstance
@@ -877,7 +877,7 @@ def process_file(self, file_path, zombies, pickle_dags=False, session=None):
         except Exception:
             self.log.exception("Error logging import errors!")
         try:
-            self.kill_zombies(zombies)
+            self.kill_zombies(dagbag, zombies)
         except Exception:
             self.log.exception("Error killing zombies!")