Bugfix task execution from runner in Windows (apache#42426)

joaopamaral · Oct 21, 2024 · 546505c · 546505c
1 parent 570480c
commit 546505c
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/airflow/jobs/local_task_job_runner.py b/airflow/jobs/local_task_job_runner.py
@@ -261,8 +261,8 @@ def handle_task_exit(self, return_code: int) -> None:
             _set_task_deferred_context_var()
         else:
             message = f"Task exited with return code {return_code}"
-            if return_code == -signal.SIGKILL:
-                message += "For more information, see https://airflow.apache.org/docs/apache-airflow/stable/troubleshooting.html#LocalTaskJob-killed"
+            if not IS_WINDOWS and return_code == -signal.SIGKILL:
+                message += ". For more information, see https://airflow.apache.org/docs/apache-airflow/stable/troubleshooting.html#LocalTaskJob-killed"
             self.log.info(message)
 
         if not (self.task_instance.test_mode or is_deferral):