Raise deep scheduler exceptions to force a process restart.

apache · Apr 5, 2016 · 86f3463 · 86f3463
1 parent 8854f28
commit 86f3463
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/airflow/jobs.py b/airflow/jobs.py
@@ -716,6 +716,7 @@ def signal_handler(signum, frame):
                     self.logger.error("Tachycardia!")
             except Exception as deep_e:
                 self.logger.exception(deep_e)
+                raise
             finally:
                 settings.Session.remove()
         executor.end()