This is an automated email from the ASF dual-hosted git repository.
potiuk pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/airflow.git
The following commit(s) were added to refs/heads/master by this push:
new 66c8af1 Update local_task_job.py (#9746)
66c8af1 is described below
commit 66c8af1f005249605d4a9f2ec9709d77262a9363
Author: Morgan Racine <[email protected]>
AuthorDate: Thu Jul 9 12:27:13 2020 -0400
Update local_task_job.py (#9746)
Removing the suicide joke.
---
airflow/jobs/local_task_job.py | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/airflow/jobs/local_task_job.py b/airflow/jobs/local_task_job.py
index 0ab163b..4b7c6d6 100644
--- a/airflow/jobs/local_task_job.py
+++ b/airflow/jobs/local_task_job.py
@@ -159,7 +159,7 @@ class LocalTaskJob(BaseJob):
):
self.log.warning(
"State of this instance has been externally set to %s. "
- "Taking the poison pill.",
+ "Terminating instance.",
ti.state
)
if ti.state == State.FAILED and ti.task.on_failure_callback:
