more worker to run

dags/dag1_calculate_hpc_worker.py

@@ -61,7 +61,7 @@ def get_new_workers(**kwargs):
       calculate_new_workers(
         queue_list=queued_tasks,
         active_jobs_dict=active_tasks,
-        max_workers_per_queue=3,
+        max_workers_per_queue=6,
         max_total_workers=10)
     for key,value in worker_to_submit.items():
       ti.xcom_push(key=key,value=value)