[
https://issues.apache.org/jira/browse/AIRFLOW-859?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kaxil Naik closed AIRFLOW-859.
------------------------------
Resolution: Not A Problem
> 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: 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
> Priority: Major
>
> 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
(v7.6.3#76005)
