Log exception in local executor (#21667)

(cherry picked from commit a0fb0bb)
apache · Mar 26, 2022 · 2ac2bf2 · 2ac2bf2
1 parent ab2073e
commit 2ac2bf2
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/airflow/executors/local_executor.py b/airflow/executors/local_executor.py
@@ -125,12 +125,12 @@ def _execute_work_in_fork(self, command: CommandType) -> str:
             ret = 0
             return State.SUCCESS
         except Exception as e:
-            self.log.error("Failed to execute task %s.", str(e))
+            self.log.exception("Failed to execute task %s.", e)
+            return State.FAILED
         finally:
             Sentry.flush()
             logging.shutdown()
             os._exit(ret)
-            raise RuntimeError('unreachable -- keep mypy happy')
 
     @abstractmethod
     def do_work(self):