diff --git a/airflow/models.py b/airflow/models.py index 9cff17d779f0d..0bfc615991006 100644 --- a/airflow/models.py +++ b/airflow/models.py @@ -825,7 +825,7 @@ def signal_handler(signum, frame): task_copy.post_execute(context=context) except (Exception, StandardError, KeyboardInterrupt) as e: self.record_failure(e, test_mode) - raise e + raise # Recording SUCCESS session = settings.Session()