(sock, name)
| 51 | |
| 52 | |
| 53 | def _bind_guard(sock, name): |
| 54 | try: |
| 55 | sock.bind(name) |
| 56 | except zmq.ZMQError: |
| 57 | logger.error( |
| 58 | "ZMQError in socket.bind('{}'). Perhaps you're \ |
| 59 | using pipes on a non-local file system. See documentation of MultiProcessRunnerZMQ \ |
| 60 | for more information.".format(name)) |
| 61 | raise |
| 62 | |
| 63 | |
| 64 | def _get_pipe_name(name): |
no test coverage detected