MCPcopy
hub / github.com/apache/airflow / end

Method end

airflow/utils/dag_processing.py:1140–1147  ·  view source on GitHub ↗

Kill all child processes on exit since we don't want to leave them as orphaned.

(self)

Source from the content-addressed store, hash-verified

1138 processor.terminate()
1139
1140 def end(self):
1141 """
1142 Kill all child processes on exit since we don't want to leave
1143 them as orphaned.
1144 """
1145 pids_to_kill = self.get_all_pids()
1146 if pids_to_kill:
1147 kill_child_processes_by_pids(pids_to_kill)
1148
1149 def emit_metrics(self):
1150 """

Callers 2

_exit_gracefullyMethod · 0.95
_run_parsing_loopMethod · 0.95

Calls 2

get_all_pidsMethod · 0.95

Tested by

no test coverage detected