Signed-off-by: Lisa Velden <[email protected]>
---
lib/jqueue/exec.py | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
diff --git a/lib/jqueue/exec.py b/lib/jqueue/exec.py
index 50b7ac6..8da1d12 100644
--- a/lib/jqueue/exec.py
+++ b/lib/jqueue/exec.py
@@ -134,13 +134,13 @@ def main():
job = context.jobqueue.SafeLoadJobFromDisk(job_id, False)
+ job.SetPid(os.getpid())
+
if secret_params:
for i in range(0, len(secret_params)):
if hasattr(job.ops[i].input, "osparams_secret") and secret_params[i]:
job.ops[i].input.osparams_secret = secret_params[i]
- job.SetPid(os.getpid())
-
execfun = mcpu.Processor(context, job_id, job_id).ExecOpCode
proc = _JobProcessor(context.jobqueue, execfun, job)
result = _JobProcessor.DEFER
--
2.4.3.573.g4eafbef
