Loading raps/engine.py +7 −3 Original line number Diff line number Diff line Loading @@ -411,8 +411,12 @@ class Engine: # Free the nodes via the resource manager. self.resource_manager.free_nodes_from_job(job) if not replay: killed_jobs = [job for job in self.running if job.end_time is not None and job.start_time + job.time_limit <= self.current_timestep] job.end_time is not None and job.start_time + job.time_limit <= self.current_timestep] else: killed_jobs = [] need_reschedule = need_reschedule or (killed_jobs != []) Loading Loading @@ -555,7 +559,7 @@ class Engine: ) else: # if job.state == JobState.RUNNING: # Error checks if job.running_time > job.time_limit and job.end_time is not None: if not replay and job.running_time > job.time_limit and job.end_time is not None: raise Exception(f"Job exceded time limit! " f"{job.running_time} > {job.time_limit}" f"\n{job}" Loading Loading
raps/engine.py +7 −3 Original line number Diff line number Diff line Loading @@ -411,8 +411,12 @@ class Engine: # Free the nodes via the resource manager. self.resource_manager.free_nodes_from_job(job) if not replay: killed_jobs = [job for job in self.running if job.end_time is not None and job.start_time + job.time_limit <= self.current_timestep] job.end_time is not None and job.start_time + job.time_limit <= self.current_timestep] else: killed_jobs = [] need_reschedule = need_reschedule or (killed_jobs != []) Loading Loading @@ -555,7 +559,7 @@ class Engine: ) else: # if job.state == JobState.RUNNING: # Error checks if job.running_time > job.time_limit and job.end_time is not None: if not replay and job.running_time > job.time_limit and job.end_time is not None: raise Exception(f"Job exceded time limit! " f"{job.running_time} > {job.time_limit}" f"\n{job}" Loading