airflow-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From David Montgomery <davidmontgom...@gmail.com>
Subject why is this alwasys running? Should be once an hour
Date Tue, 23 Aug 2016 21:09:18 GMT
I updated the dag.  In thje UI I see 0 * * * * in the schedule field



default_args = {
    'owner': 'airflow',
    'depends_on_past': False,
    "start_date": datetime.now(),
    'email': ['test@gmail.com'],
    'email_on_failure': True,
    'email_on_retry': True,
    'retries': 1,
    'retry_delay': timedelta(minutes=5)
}



dag = DAG('first_test', schedule_interval="0 * * * *",
default_args=default_args)

node_0 = PythonOperator(
    task_id='isnewdata',
    provide_context=False,
    python_callable=checkfornewdata,
    dag=dag)


node_0_1 = PythonOperator(
    task_id='fetchdata',
    provide_context=False,
    python_callable=fetchdata,
    dag=dag)

node_0_1_2 = PythonOperator(
    task_id='uploadtoes',
    provide_context=False,
    python_callable= uploadtoes,
    dag=dag)

Mime
  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message