Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- 354 context = zmq.Context()
- 355 socket = context.socket(zmq.REQ)
- 356 socket.connect('tcp://{0[interface]}:{0[ret_port]}'.format(self.opts))
- 357 socket.send(package)
- 358 payload = None
- 359 for ind in range(50):
- 360 try:
- 361 payload = salt.payload.unpackage(socket.recv(zmq.NOBLOCK))
- 362 break
- 363 except zmq.core.error.ZMQError:
- 364 print ind
- 365 time.sleep(0.01)
- 366 print payload
- 367 if not payload:
- 368 return {'jid': 0, 'minions': []}
- 369 return {'jid': payload['load']['jid'],
- 370 'minions': minions}
Advertisement
Add Comment
Please, Sign In to add comment