(wc: WorkerClient, data: bytes)
| 405 | sources_data = buf.getvalue() |
| 406 | |
| 407 | def connect(wc: WorkerClient, data: bytes) -> None: |
| 408 | # Start loading sources in each worker as soon as it is up. |
| 409 | wc.connect() |
| 410 | if not wc.connected: |
| 411 | # Caller should detect this and fail gracefully. |
| 412 | return |
| 413 | wc.conn.write_bytes(data) |
| 414 | |
| 415 | # We don't wait for workers to be ready until they are actually needed. |
| 416 | for worker in workers: |
nothing calls this directly
no test coverage detected
searching dependent graphs…