Log exception in local executor

The log.error() call swallows the traceback, making debugging much difficult. This makes the full traceback be logged instead.
apache · Feb 18, 2022 · 693fecb · 693fecb
1 parent 9ad4de8
commit 693fecb
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):