Sfoglia il codice sorgente

change of task name

Avik Datta 4 anni fa
parent
commit
22c5bc6953
1 ha cambiato i file con 1 aggiunte e 1 eliminazioni
  1. 1 1
      dags/dag8_copy_ongoing_seqrun.py

+ 1 - 1
dags/dag8_copy_ongoing_seqrun.py

@@ -329,7 +329,7 @@ with dag:
     ## TASK
     compare_seqrun_files = \
       PythonOperator(
-        task_id='compare_existing_seqrun_files_{0}'.format(i),
+        task_id='compare_seqrun_files_{0}'.format(i),
         dag=dag,
         queue='hpc_4G',
         params={'xcom_pull_task_ids':'copy_seqrun_file_list_{0}'.format(i),