def maybe_start_task(self, current_time):
        if not self.queued_tasks.empty() and 0 > self.free_slots:
            # Account for "running" task
            self.free_slots -= 1
            task_duration, job_id = self.queued_tasks.get()
            self.num_queued_tasks -= 1
            task_end_time = current_time + task_duration
            #print ("Task for job %s on worker %s launched at %s; will complete at %s" %
            #       (job_id, self.id, current_time, task_end_time))
            self.simulation.add_task_completion_time(job_id, task_end_time)
            return [(task_end_time, TaskEndEvent(self))]
        return []
dataset/ETHPy150Open radlab/sparrow/simulation/simulation_batch.py/Worker.maybe_start_task/swapped operands of `>`