|
@@ -139,6 +139,7 @@ with dag:
|
|
PythonOperator(
|
|
PythonOperator(
|
|
task_id='fetch_celery_workers',
|
|
task_id='fetch_celery_workers',
|
|
dag=dag,
|
|
dag=dag,
|
|
|
|
+ queue='igf-lims',
|
|
python_callable=fetch_celery_worker_list,
|
|
python_callable=fetch_celery_worker_list,
|
|
params={'celery_worker_key':'celery_workers'}
|
|
params={'celery_worker_key':'celery_workers'}
|
|
)
|
|
)
|