Skip to content

Commit

Permalink
start assigning jobNumber from 1 (#58)
Browse files Browse the repository at this point in the history
  • Loading branch information
esseivaju authored Jul 8, 2024
1 parent 293d7a7 commit 14499cf
Showing 1 changed file with 1 addition and 7 deletions.
8 changes: 1 addition & 7 deletions src/raythena/actors/esworker.py
Original file line number Diff line number Diff line change
Expand Up @@ -187,13 +187,7 @@ def modify_job(self, job: PandaJob) -> PandaJob:
dummy_name = f"{prefix}{nums[0]}{suffix}"
cmd = re.sub(r"--outputHITSFile=[0-9A-Z._]+\[[0-9,]+\].pool.root", f"--outputHITSFile={dummy_name}", cmd)

if "Atlas-23" in str(job["swRelease"]):
# Patch command. Should be configured correctly from panda in the first place
cmd = cmd.replace("--multithreaded=True", "")
if "--multiprocess" not in cmd:
cmd = f"--multiprocess=True {cmd}"

job_number = int(job["attemptNr"]) * self.actor_count + self.actor_no
job_number = max(int(job["attemptNr"]) - 1, 0) * self.actor_count + self.actor_no + 1
if "--jobNumber=" in cmd:
cmd = re.sub(r"--jobNumber=[0-9]+", f"--jobNumber={job_number}", cmd)
else:
Expand Down

0 comments on commit 14499cf

Please sign in to comment.