Airflow dag, unsure of how to chain the tasks

54 views Asked by At

I have a dag which essentially does the business questions task for each cleaned table because of how i set my dependencies

run_mount_bucket >> run_loading_uncleaned_tables >> [run_cleaning_df_user, run_cleaning_df_pin, run_cleaning_df_geo] >> run_business_questions

I figured it should've been as easy as doing this

run_mount_bucket >> run_loading_uncleaned_tables >> [run_cleaning_df_user, run_cleaning_df_pin, run_cleaning_df_geo] run_business_questions

which caused a dag import error due to incorrect syntax, tried googling it but cannot find a correct resource to look at

0

There are 0 answers