(processor, q: Queue, result_q: Queue)
| 277 | |
| 278 | |
| 279 | def post_process_loop(processor, q: Queue, result_q: Queue): |
| 280 | results = [] |
| 281 | while True: |
| 282 | preds = q.get() |
| 283 | if preds is not None: |
| 284 | preds = CSVDataset.post_process(preds, processor) |
| 285 | results.extend(preds) |
| 286 | else: |
| 287 | break |
| 288 | result_q.put(results) |
| 289 | |
| 290 | |
| 291 | def main(): |
nothing calls this directly
no test coverage detected