even @hourly is not working. Fires every cycle. wow
On Wed, Aug 24, 2016 at 5:09 AM, David Montgomery <[email protected]
> wrote:
> 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': ['[email protected]'],
> '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)
>
>
