(self, delay, task)
| 4270 | log.debug("Ignoring schedule_unique for already-scheduled task: %r", task) |
| 4271 | |
| 4272 | def _insert_task(self, delay, task): |
| 4273 | if not self.is_shutdown: |
| 4274 | run_at = time.time() + delay |
| 4275 | self._scheduled_tasks.add(task) |
| 4276 | self._queue.put_nowait((run_at, next(self._count), task)) |
| 4277 | else: |
| 4278 | log.debug("Ignoring scheduled task after shutdown: %r", task) |
| 4279 | |
| 4280 | def run(self): |
| 4281 | while True: |
no test coverage detected