Close connection to a worker.
(self, worker_pid)
| 644 | return reader, writer |
| 645 | |
| 646 | def _close_worker_connection(self, worker_pid): |
| 647 | """Close connection to a worker.""" |
| 648 | if worker_pid in self.worker_connections: |
| 649 | _reader, writer = self.worker_connections.pop(worker_pid) |
| 650 | writer.close() |
| 651 | |
| 652 | # ------------------------------------------------------------------------- |
| 653 | # Stash (shared state) operations - handled directly in arbiter |