[
https://issues.apache.org/jira/browse/AIRFLOW-3590?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stefan Seelmann updated AIRFLOW-3590:
-
Description:
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:
[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:
[2018-12-15 18:59:13,698] {jobs.py:1293} INFO - Setting the following 1 tasks
to queued state:
[2018-12-15 18:59:13,699] {jobs.py:1335} INFO - Sending ('hello_world', 'wait',
datetime.datetime(2018, 12, 15, 18, 50, tzinfo=), 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 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}
> 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:
>
> [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:
>
> [2018-12-15 18:59:13,698] {jobs.py:1293} INFO - Setting the following 1 tasks
> to queued state:
>
> [2018-12-15 18:59:13,699] {jobs.py:1335} INFO - Sending ('hello_world',
> 'wait', datetime.datetime(2018, 12, 15, 18, 50, tzinfo=), 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 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)
