diff --git a/airflow/task/task_runner/standard_task_runner.py b/airflow/task/task_runner/standard_task_runner.py index 83b775d7f5f01..15830d568be69 100644 --- a/airflow/task/task_runner/standard_task_runner.py +++ b/airflow/task/task_runner/standard_task_runner.py @@ -85,6 +85,11 @@ def _start_by_fork(self): args.func(args, dag=self.dag) return_code = 0 except Exception: + self.log.exception( + "Failed to execute job %s fo task %s", + self._task_instance.job_id, + self._task_instance.task_id, + ) return_code = 1 finally: # Explicitly flush any pending exception to Sentry if enabled