소스 검색

fix for param pool

Avik Datta 3 년 전
부모
커밋
74987000ee
1개의 변경된 파일1개의 추가작업 그리고 1개의 파일을 삭제
  1. 1 1
      dags/dag10_nextflow_atacseq_pipeline.py

+ 1 - 1
dags/dag10_nextflow_atacseq_pipeline.py

@@ -81,7 +81,7 @@ with dag:
       task_id='run_nf_atacseq',
       dag=dag,
       queue='hpc_4G_long',
-      pool_slots='nextflow_hpc',
+      pool='nextflow_hpc',
       python_callable=run_nf_command_func,
       params={'nextflow_command_xcom_task':'prep_nf_atacseq_run',
               'nextflow_command_xcom_key':'nexflow_command',