changed events per core
This commit is contained in:
+2
-2
@@ -178,8 +178,8 @@ def run_batch(
|
||||
assert nEvents > 0
|
||||
|
||||
nCores = multiprocessing.cpu_count()
|
||||
#make sure to adjust cores such that at least 200 events are run per core
|
||||
nCores = min(nCores, nEvents // 200 + 1)
|
||||
#make sure to adjust cores such that at least 80 events are run per core
|
||||
nCores = min(nCores, nEvents // 80 + 1)
|
||||
|
||||
print(f"Running on {nCores} cores")
|
||||
nEventsPerCore = nEvents // nCores
|
||||
|
||||
Reference in New Issue
Block a user