Commit 04692718 authored by Hines, Jesse's avatar Hines, Jesse
Browse files

Fix bug in update_jobs

Scale can be 0
parent e3f8b6b4
Loading
Loading
Loading
Loading
+1 −1
Original line number Diff line number Diff line
@@ -222,7 +222,7 @@ class Telemetry:

    def update_jobs(self, jobs: list[Job]):
        """ Updates jobs with new scale or random start times """
        if self.kwargs.get("scale") is not None:
        if self.kwargs.get("scale"):
            for job in jobs:
                job.nodes_required = random.randint(1, self.kwargs['scale'])
                job.scheduled_nodes = None  # Setting to None triggers scheduler to assign nodes