(self, item)
| 459 | raise RuntimeError("Async target cache writer failed.") from self._exception |
| 460 | |
| 461 | def _put(self, item): |
| 462 | while True: |
| 463 | self._raise_if_failed() |
| 464 | try: |
| 465 | self.queue.put(item, timeout=1.0) |
| 466 | return |
| 467 | except queue.Full: |
| 468 | continue |
| 469 | |
| 470 | def write_sample( |
| 471 | self, |
no test coverage detected