You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@airflow.apache.org by Kripakaran Jayakumar <kj...@gsngames.com> on 2018/05/18 23:01:25 UTC

Subdag Not Triggered from main dag

Hi ,

I have a subdag , which has its own schedule .

cc_subdag:

sub_dag_cc = DAG('main_dag.sub_dag_cc',
                       schedule_interval='40 10,15,21,00 * * *',  # 3
am , 10 am , 9 PM , 12 AM PST
                       start_date=datetime(2018, 5, 9),
                       default_args=default_args
                       )

t_import_data = CImporter(task_id='t_import_cc_data',
                                          range_days=14,
                                          sla=timedelta(minutes=90),
                                          dag=sub_dag_singular)


I have a main dag  ,

main_dag:

main_dag = DAG(
    dag_id='main_dag',
    default_args=default_args,
    start_date=datetime(2018, 4, 29),
    schedule_interval='30 12 * * *',  # 5 30 am PST
    max_active_runs=1
)


subdag_cc = SubDagOperator(
    subdag=sub_dag_cc,
    task_id='subdag_cc',
    dag=main_dag,
    email_on_failure=True,
    email=['etl@xx.com'],
    trigger_rule=TriggerRule.ALL_DONE
)

Question :

Scheduler has identified subdag has its own schedule and it works
absolutely fine.

but when the main dag calls the subdag it exits without actually
executing the subdag.

When i check the logs it says "No run dates were found for the given
dates and dag interval"

Wondering what am i doing wrong .

any help is much appreciated , thank you