Put batch of experience.
(self, exp_bytes: bytes)
| 369 | return self.queue.qsize() |
| 370 | |
| 371 | async def put_batch(self, exp_bytes: bytes) -> None: |
| 372 | """Put batch of experience.""" |
| 373 | exp_list = Experience.deserialize_many(exp_bytes) |
| 374 | await self.queue.put(exp_list) |
| 375 | if self.writer is not None: |
| 376 | await self.writer.write(exp_list) |
| 377 | |
| 378 | async def get_batch(self, batch_size: int, timeout: float, min_model_version: int = 0) -> bytes: |
| 379 | """Get batch of experience.""" |
nothing calls this directly
no test coverage detected