def send_process_status(self, status):
""" This method sends a serialized form of the process status
through the socket. """
self.logger.trace('send Process Status {}'.format(status))
self.socket.send_string(EventHeaders.PROCESS_STATUS, zmq.SNDMORE)
self.socket.send_json(status.serial())
评论列表
文章目录