[jira] [Created] (AIRFLOW-859) airflow trigger_dag not working

["Stefano Tiani-Tanzi (JIRA)" <ji...@apache.org>]

Stefano Tiani-Tanzi created AIRFLOW-859:
-------------------------------------------

             Summary: airflow trigger_dag <dag_name> not working
                 Key: AIRFLOW-859
                 URL: https://issues.apache.org/jira/browse/AIRFLOW-859
             Project: Apache Airflow
          Issue Type: Bug
    Affects Versions: Airflow 1.7.1.3
         Environment: Using Airflow 1.7.1.3 on Amazon Web Services (date +%Z # timezone name
 displays UTC).
Airflow using Mariadb also on AWS (maria db system_time_zone set to UTC) 
            Reporter: Stefano Tiani-Tanzi


Hi,
I have a simple DAG ( code at end of this message ).
The DAG loads OK using CLI "airflow list_dags".

In Airflow webpage the DAG is set to "On".
I try and trigger the dag using CLI "airflow trigger_dag trigger_dag_v1" and get feedback as follows:

[2017-02-10 18:20:12,969] {__init__.py:36} INFO - Using executor LocalExecutor
[2017-02-10 18:20:13,374] {cli.py:142} INFO - Created <DagRun trigger_dag_v1 @ 2017-02-10 18:20:13.342199: manual__2017-02-10T18:20:13.342199, externally triggered: True>

However, the dag does not start/run.
I can see in the web interface ( using Browse|Dag Runs ) that the run is at "Failed" status but there are no logs associated with the run. Also in the Tree view no runs appear.

Airflow server and db are both set to UTC and the DAG is switched on in the web UI.

Have I missed something or am I doing something incorrectly?
Any help would be much appreciated.

Many thanks

Stefano

import json
from airflow import DAG
from airflow.models import Variable
from airflow.operators import DummyOperator
from datetime import datetime, timedelta

default_args = {
    'owner': 'stef',
    'start_date': datetime(2017, 01, 01),
    'retries': 1,
    'retry_delay': timedelta(minutes=3),
    'depends_on_past': False,
    'wait_for_downstream': True,
    'provide_context': True
}

dag = DAG('trigger_dag_v1', default_args=default_args, schedule_interval=None)

task_dummy = DummyOperator(
    task_id='dummy',
    dag=dag)   




--
This message was sent by Atlassian JIRA
(v6.3.15#6346)