Merge pull request #1540 from desihub/mpirankbug

Fix desi_proc specex wrapper MPI rank bug for single camera
desihub · Dec 20, 2021 · e822758 · e822758
2 parents fe85bab + 8e41121
commit e822758
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/py/desispec/workflow/desi_proc_funcs.py b/py/desispec/workflow/desi_proc_funcs.py
@@ -299,7 +299,8 @@ def determine_resources(ncameras, jobdesc, queue, nexps=1, forced_runtime=None,
 
     nspectro = (ncameras - 1) // 3 + 1
     if jobdesc in ('ARC', 'TESTARC'):
-        ncores, runtime = 10 * ncameras + 1, 45 # + 1 for worflow.schedule scheduler proc
+        ncores          = 20 * (10*(ncameras+1)//20) # lowest multiple of 20 exceeding 10 per camera
+        ncores, runtime = ncores + 1, 45             # + 1 for worflow.schedule scheduler proc
     elif jobdesc in ('FLAT', 'TESTFLAT'):
         ncores, runtime = 20 * nspectro, 25
     elif jobdesc in ('SKY', 'TWILIGHT', 'SCIENCE','PRESTDSTAR','POSTSTDSTAR'):