01kq8tw89q3c5y33tzgs4mq3jk.py committed by groupuser

This commit is contained in:
airflow 2026-04-28 02:15:02 +00:00
parent 112b308769
commit 336b79df35

@ -99,17 +99,17 @@ def dag_template():
# USER_EDIT_TASK_START
t1 = CheetahDatasetOperator(
task_id="download_dataset",
dataset_sn=466,
output_path="raw_data",
)
task_id="download_dataset",
dataset_sn=466,
output_path="raw_data",
)
t2 = PythonOperator(
task_id="copy_dataset",
python_callable=_copy_dataset_only,
)
t2 = PythonOperator(
task_id="copy_dataset",
python_callable=_copy_dataset_only,
)
t1 >> t2
t1 >> t2
# USER_EDIT_TASK_END
return dag