This is an automated email from the ASF dual-hosted git repository.
jscheffl pushed a commit to branch v2-10-test
in repository https://gitbox.apache.org/repos/asf/airflow.git
The following commit(s) were added to refs/heads/v2-10-test by this push:
new 21ddd3e834 Bugfix task execution from runner in Windows (#42426)
(#42478)
21ddd3e834 is described below
commit 21ddd3e834c5a4d2e8f96be7af2053d749f106e2
Author: Jens Scheffler <[email protected]>
AuthorDate: Wed Sep 25 22:10:26 2024 +0200
Bugfix task execution from runner in Windows (#42426) (#42478)
(cherry picked from commit 737900a0a66d6987c5931dee34a634e32c812490)
---
airflow/jobs/local_task_job_runner.py | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
diff --git a/airflow/jobs/local_task_job_runner.py
b/airflow/jobs/local_task_job_runner.py
index 95a471f239..cdc3c1b624 100644
--- a/airflow/jobs/local_task_job_runner.py
+++ b/airflow/jobs/local_task_job_runner.py
@@ -261,8 +261,8 @@ class LocalTaskJobRunner(BaseJobRunner, LoggingMixin):
_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):
