Explorar o código

fix for missing queue

Avik Datta %!s(int64=3) %!d(string=hai) anos
pai
achega
8906ce9a70
Modificáronse 1 ficheiros con 1 adicións e 0 borrados
  1. 1 0
      dags/dag18_upload_and_trigger_analysis.py

+ 1 - 0
dags/dag18_upload_and_trigger_analysis.py

@@ -67,6 +67,7 @@ with dag:
             PythonOperator(
                 task_id="load_analysis_design_{0}".format(i),
                 dag=dag,
+                queue='hpc_4G',
                 params={
                     "task_index": i,
                     "load_design_xcom_key": "load_design",