def wait_task_to_finish(self):
        try:
            task = self.finished_queue.get(timeout=60.0)
        except queue.Empty:
            self.log.warning(
                "tasks taking long to finish: %s and %r tasks waiting to be started",
                ", ".join(str(task) for task in self.started), len(self.not_started))
            return

        self.log.debug("task %s finished, took %.2f seconds", task,
                       (task.start_time - task.stop_time))
        self.started.remove(task)
        self.stopped.add(task)
        self.finished_queue.task_done()
dataset/ETHPy150Open ohmu/poni/poni/work.py/Runner.wait_task_to_finish/swapped operands of `-`