Skip to content

Commit 14499cf

Browse files
authored
start assigning jobNumber from 1 (#58)
1 parent 293d7a7 commit 14499cf

File tree

1 file changed

+1
-7
lines changed

1 file changed

+1
-7
lines changed

src/raythena/actors/esworker.py

+1-7
Original file line numberDiff line numberDiff line change
@@ -187,13 +187,7 @@ def modify_job(self, job: PandaJob) -> PandaJob:
187187
dummy_name = f"{prefix}{nums[0]}{suffix}"
188188
cmd = re.sub(r"--outputHITSFile=[0-9A-Z._]+\[[0-9,]+\].pool.root", f"--outputHITSFile={dummy_name}", cmd)
189189

190-
if "Atlas-23" in str(job["swRelease"]):
191-
# Patch command. Should be configured correctly from panda in the first place
192-
cmd = cmd.replace("--multithreaded=True", "")
193-
if "--multiprocess" not in cmd:
194-
cmd = f"--multiprocess=True {cmd}"
195-
196-
job_number = int(job["attemptNr"]) * self.actor_count + self.actor_no
190+
job_number = max(int(job["attemptNr"]) - 1, 0) * self.actor_count + self.actor_no + 1
197191
if "--jobNumber=" in cmd:
198192
cmd = re.sub(r"--jobNumber=[0-9]+", f"--jobNumber={job_number}", cmd)
199193
else:

0 commit comments

Comments
 (0)