diff --git a/airflow/cli/commands/dag_processor_command.py b/airflow/cli/commands/dag_processor_command.py index 183b77dbe26b1..db7ed443a3122 100644 --- a/airflow/cli/commands/dag_processor_command.py +++ b/airflow/cli/commands/dag_processor_command.py @@ -70,11 +70,9 @@ def dag_processor(args): ) with ctx: try: - manager.register_exit_signals() manager.start() finally: manager.terminate() manager.end() else: - manager.register_exit_signals() manager.start()