(self, device: torch.device, fn, *args, **kwargs)
| 60 | result_q.put((None, e)) |
| 61 | |
| 62 | def submit(self, device: torch.device, fn, *args, **kwargs): |
| 63 | self._work_queues[device].put((fn, args, kwargs)) |
| 64 | |
| 65 | def get_result(self, device: torch.device): |
| 66 | return self._result_queues[device].get() |
no test coverage detected