[
https://issues.apache.org/jira/browse/AIRFLOW-3590?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16755408#comment-16755408
]
ASF subversion and git services commented on AIRFLOW-3590:
----------------------------------------------------------
Commit 2f688f69cb5f59db888041228dfb4a2ae06e5644 in airflow's branch
refs/heads/master from Stefan Seelmann
[ https://gitbox.apache.org/repos/asf?p=airflow.git;h=2f688f6 ]
AIRFLOW-3590: Change log message of executor exit status (#4616)
Try to make the log message clearer in the presence of rescheduled tasks -
i.e that the task exited with 0/1, not the status of the task, without having
each
executor having to know about reschedule or other states we might introduce.
> In case of reschedule executor should not log success
> -----------------------------------------------------
>
> Key: AIRFLOW-3590
> URL: https://issues.apache.org/jira/browse/AIRFLOW-3590
> Project: Apache Airflow
> Issue Type: Improvement
> Components: executor
> Reporter: Stefan Seelmann
> Assignee: Stefan Seelmann
> Priority: Major
> Fix For: 2.0.0
>
>
> Based on comment from [~ashb]
> https://github.com/apache/airflow/pull/3596#issuecomment-447590657
> The scheduler (when using SequentialExecutor, but that isn't relevant) logs
> this task as Success!
> {code}
> [2018-12-15 18:59:13,635] {jobs.py:1100} INFO - 1 tasks up for execution:
> <TaskInstance: hello_world.wait 2018-12-15 18:50:00+00:00 [scheduled]>
> [2018-12-15 18:59:13,649] {jobs.py:1135} INFO - Figuring out tasks to run in
> Pool(name=None) with 128 open slots and 1 task instances in queue
> [2018-12-15 18:59:13,656] {jobs.py:1171} INFO - DAG hello_world has 0/16
> running and queued tasks
> [2018-12-15 18:59:13,656] {jobs.py:1209} INFO - Setting the follow tasks to
> queued state:
> <TaskInstance: hello_world.wait 2018-12-15 18:50:00+00:00 [scheduled]>
> [2018-12-15 18:59:13,698] {jobs.py:1293} INFO - Setting the following 1 tasks
> to queued state:
> <TaskInstance: hello_world.wait 2018-12-15 18:50:00+00:00 [queued]>
> [2018-12-15 18:59:13,699] {jobs.py:1335} INFO - Sending ('hello_world',
> 'wait', datetime.datetime(2018, 12, 15, 18, 50, tzinfo=<Timezone [UTC]>), 1)
> to executor with priority 2 and queue default
> [2018-12-15 18:59:13,701] {base_executor.py:56} INFO - Adding to queue:
> airflow run hello_world wait 2018-12-15T18:50:00+00:00 --local -sd
> /Users/ash/airflow/dags/foo.py
> [2018-12-15 18:59:13,742] {sequential_executor.py:45} INFO - Executing
> command: airflow run hello_world wait 2018-12-15T18:50:00+00:00 --local -sd
> /Users/ash/airflow/dags/foo.py
> [2018-12-15 18:59:15,558] {__init__.py:51} INFO - Using executor
> SequentialExecutor
> [2018-12-15 18:59:15,755] {models.py:273} INFO - Filling up the DagBag from
> /Users/ash/airflow/dags/foo.py
> [2018-12-15 18:59:15,833] {cli.py:530} INFO - Running <TaskInstance:
> hello_world.wait 2018-12-15T18:50:00+00:00 [queued]> on host
> themisto.localdomain
> [2018-12-15 18:59:21,427] {jobs.py:1439} INFO - Executor reports
> hello_world.wait execution_date=2018-12-15 18:50:00+00:00 as success for
> try_number 1
> {code}
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)
