(self)
| 113 | _TIMEOUT_EXPIRED = subprocess.TimeoutExpired |
| 114 | |
| 115 | def __del__(self): |
| 116 | try: |
| 117 | # Shut down the session first so remote nodes can exit gracefully. |
| 118 | if self.sess is not None: |
| 119 | self.sess.shutdown() |
| 120 | finally: |
| 121 | for node in self.remote_nodes: |
| 122 | try: |
| 123 | node.wait(timeout=10) |
| 124 | except self._TIMEOUT_EXPIRED: |
| 125 | node.kill() |
| 126 | node.wait() |
| 127 | |
| 128 | |
| 129 | def create_socket_session(num_workers): |