Skip to content

Commit

Permalink
fixup! Rewite LocalExecutor to be simpler, and to shutdown cleanly on…
Browse files Browse the repository at this point in the history
… Python 3.10+
  • Loading branch information
ashb committed Nov 20, 2024
1 parent 2f7d6c5 commit da01d42
Showing 1 changed file with 0 additions and 3 deletions.
3 changes: 0 additions & 3 deletions airflow/executors/local_executor.py
Original file line number Diff line number Diff line change
Expand Up @@ -225,9 +225,6 @@ def _check_workers(self, can_start: bool = True):
if not proc.is_alive():
to_remove.add(pid)
proc.close()
if proc.exitcode is not None and proc.exitcode > 0:
# The process died!
...

if to_remove:
self.workers = {pid: proc for pid, proc in self.workers.items() if pid not in to_remove}
Expand Down

0 comments on commit da01d42

Please sign in to comment.