Fix maxevents (#59)

* set maxEvents to the number of events per file * set maxEvents to the smallest of 500 and nEventsPerInputFile
PanDAWMS · Jul 26, 2024 · 1ffaa77 · 1ffaa77
1 parent 14499cf
commit 1ffaa77
Showing 1 changed file with 6 additions and 0 deletions.
diff --git a/src/raythena/actors/esworker.py b/src/raythena/actors/esworker.py
@@ -193,6 +193,12 @@ def modify_job(self, job: PandaJob) -> PandaJob:
         else:
             cmd = f"{cmd} --jobNumber={job_number} "
 
+        maxEvents = min(500, job['nEventsPerInputFile'])
+        if "--maxEvents=" in cmd:
+            cmd = re.sub(r"--maxEvents=[0-9]+", f"--maxEvents={maxEvents}", cmd)
+        else:
+            cmd = f"{cmd} --maxEvents={maxEvents} "
+
         job["jobPars"] = cmd
         return job