From c0bce7bc72e0c78125c5a701103b0c400df449f4 Mon Sep 17 00:00:00 2001 From: Michele Simionato Date: Thu, 18 Jan 2024 19:43:53 +0100 Subject: [PATCH] Fix --- openquake/engine/engine.py | 3 +-- 1 file changed, 1 insertion(+), 2 deletions(-) diff --git a/openquake/engine/engine.py b/openquake/engine/engine.py index 8f9f65d5a38c..6c3072d770e2 100644 --- a/openquake/engine/engine.py +++ b/openquake/engine/engine.py @@ -377,9 +377,8 @@ def run_jobs(jobctxs, concurrent_jobs=None): config.zworkers.host_cores == '127.0.0.1 -1') if use_zmq: # use multispawn with zmq on a single machine - orig_dist = os.environ.get('OQ_DISTRIBUTE', '') + orig_dist = parallel.oq_distribute() os.environ['OQ_DISTRIBUTE'] = 'zmq' - dist = parallel.oq_distribute() if hc_id: job = logs.dbcmd('get_job', hc_id)