Fixed oq workers status [ci skip]

gem · Sep 14, 2024 · dd2b709 · dd2b709
1 parent 46e47c1
commit dd2b709
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/openquake/baselib/workerpool.py b/openquake/baselib/workerpool.py
@@ -21,6 +21,7 @@
 import shutil
 import socket
 import getpass
+import tempfile
 import functools
 import subprocess
 from datetime import datetime
@@ -276,7 +277,7 @@ def __init__(self, ctrl_port=1909, num_workers=-1, job_id=0):
         else:
             self.num_workers = num_workers
         self.scratch = parallel.scratch_dir(job_id)
-        self.executing = os.path.join(self.scratch, 'executing')
+        self.executing = tempfile.mkdtemp(dir=self.scratch)
         try:
             os.mkdir(self.executing)
         except FileExistsError:  # already created by another WorkerPool