()
| 234 | name="worker_result_queue") |
| 235 | |
| 236 | def notify_proxy_threads_to_quit(): |
| 237 | # Signal the dispatcher thread in the proxy to quit |
| 238 | if result_queue is not None: |
| 239 | result_queue.put(None) |
| 240 | else: |
| 241 | assert result_queues is not None |
| 242 | for q in result_queues: |
| 243 | q.put(None) |
| 244 | |
| 245 | postprocess_worker_futures = [] |
| 246 | if is_leader and postproc_worker_config.enabled: |