dodox/Slate
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

Make sure we consume the conf instead of just reading it

Browse Source
This commit is contained in:
Dominik Moritz Roth 2023-07-09 16:21:33 +02:00
parent 7bc7f319d8
commit fd43bbabb6
1 changed files with 8 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

14
slate/slate.py
View File

@ -126,16 +126,18 @@ class Slate():
child_keys = '.'.join(keys_arr[1:]) child_keys = '.'.join(keys_arr[1:])
return self.consume(child, child_keys, default=default, **kwargs) return self.consume(child, child_keys, default=default, **kwargs)
def _calc_num_jobs(self, schedulerC): def _calc_num_jobs(self, schedC):
reps = schedulerC.get('repetitions', 1) schedulerC = copy.deepcopy(schedC)
agents_per_job = schedulerC.get('agents_per_job', 1) reps = schedulerC.consume('repetitions', 1)
reps_per_agent = schedulerC.get('reps_per_agent', 1) agents_per_job = schedulerC.consume('agents_per_job', 1)
reps_per_agent = schedulerC.consume('reps_per_agent', 1)
reps_per_job = reps_per_agent * agents_per_job reps_per_job = reps_per_agent * agents_per_job
jobs_needed = math.ceil(reps / reps_per_job) jobs_needed = math.ceil(reps / reps_per_job)
return jobs_needed return jobs_needed
def _reps_for_job(self, schedulerC, job_id): def _reps_for_job(self, schedC, job_id):
reps = schedulerC.get('repetitions', 1) schedulerC = copy.deepcopy(schedC)
reps = schedulerC.consume('repetitions', 1)
if job_id == None: if job_id == None:
return list(range(0, reps)) return list(range(0, reps))
num_jobs = self._calc_num_jobs(schedulerC) num_jobs = self._calc_num_jobs(schedulerC)