01kkdtkqw5y88gsfyxna56cesg.py committed by groupuser

This commit is contained in:
airflow 2026-03-16 04:11:55 +00:00
parent 95eacdf38f
commit cd44bfee62

@ -103,12 +103,12 @@ def dag_template():
output_path="raw_data", output_path="raw_data",
) )
t2 = PythonOperator( t2 = PythonOperator(
task_id="copy_dataset", task_id="copy_dataset",
python_callable=_copy_dataset_only, python_callable=_copy_dataset_only,
) )
t1 >> t2 t1 >> t2
# USER_EDIT_TASK_END # USER_EDIT_TASK_END
return dag return dag