浏览代码

changes to dag8

Avik Datta 4 年之前
父节点
当前提交
29ac5fd6c7
共有 1 个文件被更改,包括 1 次插入1 次删除
  1. 1 1
      dags/dag8_test2.py

+ 1 - 1
dags/dag8_test2.py

@@ -44,7 +44,7 @@ with dag:
     BranchPythonOperator(
       task_id='calculate_new_worker_size_and_branch',
       dag=dag,
-      python_callable=lambda: ['copy_files_to_hpc1','copy_files_to_hpc2'],
+      python_callable=lambda: ['copy_files_to_hpc1',],
       queue='hpc_4G')
   copy_files_to_hpc1 = \
     BashOperator(