trigger_dag writes creates dag_run record but doesn't start DAG. Example example_trigger_controller_dag doesn't start also

508 views
Skip to first unread message

Serega Sheypak

unread,
Apr 19, 2016, 10:25:44 AM4/19/16
to Airflow
Hi, I'm trying to figure out how does trigger_dag works.
here is my command and output:
bash-4.1# airflow trigger_dag c1604_na 
[2016-04-19 14:15:06,454] {__init__.py:36} INFO - Using executor SequentialExecutor 
[2016-04-19 14:15:06,692] {cli.py:107} INFO - Created <DagRun c1604_na @ 2016-04-19 14:15:06.673657: manual__2016-04-19T14:15:06.673657, externally triggered: True>

I go to webserver UI and see that there is the dag_run in RUNNING stage.
Database table has the the record for the dag_run I see. But nothing happens. DAG doesn't start.
My DAG default args are:

default_args = {
    'owner': 'airflow',
    'start_date': datetime.now()
}
DAG schedule_interval is set to '@once'

BTW, I tried to run example_trigger_controller_dag

bash-4.1# airflow trigger_dag example_trigger_controller_dag
[2016-04-19 14:21:42,073] {__init__.py:36} INFO - Using executor SequentialExecutor
[2016-04-19 14:21:42,318] {cli.py:107} INFO - Created <DagRun example_trigger_controller_dag @ 2016-04-19 14:21:42.299106: manual__2016-04-19T14:21:42.299106, externally triggered: True>

Webserver UI tab named "DAGs" is not updated also. I see DAGs there, but their statues are not updated. 

Siddharth Anand

unread,
Apr 20, 2016, 8:19:40 PM4/20/16
to Airflow
Are you running a scheduler? Also, is your entire system running on UTC (DB, scheduler, webserver)?

-s

Serega Sheypak

unread,
Apr 21, 2016, 4:41:15 AM4/21/16
to Airflow
Hi, yes, you are right, it was my mistake.
Backfill worked out of the box w/o scheduler and it confused me. I've started scheduler and now it runs.
Reply all
Reply to author
Forward
0 new messages