airflow-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Siddharth Anand (JIRA)" <j...@apache.org>
Subject [jira] [Commented] (AIRFLOW-396) DAG status still running when all its tasks are complete
Date Thu, 04 Aug 2016 19:32:21 GMT

    [ https://issues.apache.org/jira/browse/AIRFLOW-396?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15408366#comment-15408366
] 

Siddharth Anand commented on AIRFLOW-396:
-----------------------------------------

Can you provide the following : 
* Tree view screenshot
* Graph view screenshot that is top to bottom, not left to right
* Task Run screen shot filtered to show tasks for this dag 

Also, are you running UTC everywhere, including your DB? If not, that could be the explanation.



> DAG status still running when all its tasks are complete
> --------------------------------------------------------
>
>                 Key: AIRFLOW-396
>                 URL: https://issues.apache.org/jira/browse/AIRFLOW-396
>             Project: Apache Airflow
>          Issue Type: Bug
>          Components: DagRun, scheduler
>    Affects Versions: Airflow 1.7.0
>            Reporter: Nadeem Ahmed Nazeer
>            Assignee: Siddharth Anand
>            Priority: Minor
>         Attachments: DagRuns.png, Dag_code.txt, Dag_no_input_files_still_running_state.png
>
>
> Hello,
> I am facing a situation with Airflow where it doesn't flag the DAG's as success even
though all of the tasks in that DAG are complete.
> I have a BranchPythonOperator which forks into running all downstream tasks or just a
single task (dummy operator as an endpoint) depending if files exists to be processed or not
for that cycle.
> I see that in the DAG's that go to the dummy operator, the status of the DAG always shows
running where its complete. I can't get to figure out what is stopping the scheduler from
marking this DAG success. Since it is in running state, every time the scheduler checks the
status of this DAG which is unnecessary.
> My airflow version is 1.7.0. This is the only version that works for me when it comes
to scheduler. Any version above this, the scheduler gets stuck without a trace and wouldn't
schedule anything.
> Please advise.



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)

Mime
View raw message