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