[
https://issues.apache.org/jira/browse/AIRFLOW-3590?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16755407#comment-16755407
]
ASF GitHub Bot commented on AIRFLOW-3590:
-----------------------------------------
ashb commented on pull request #4616: AIRFLOW-3590: Change log message of
executor exit status
URL: https://github.com/apache/airflow/pull/4616
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
[email protected]
> 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)
