Show More
@@ -131,21 +131,10 b' class Kernel(SessionFactory):' | |||||
131 |
|
131 | |||
132 | def abort_queue(self, stream): |
|
132 | def abort_queue(self, stream): | |
133 | while True: |
|
133 | while True: | |
134 | try: |
|
134 | idents,msg = self.session.recv(stream, zmq.NOBLOCK, content=True) | |
135 | msg = self.session.recv(stream, zmq.NOBLOCK,content=True) |
|
135 | if msg is None: | |
136 | except zmq.ZMQError as e: |
|
136 | return | |
137 | if e.errno == zmq.EAGAIN: |
|
|||
138 | break |
|
|||
139 | else: |
|
|||
140 | return |
|
|||
141 | else: |
|
|||
142 | if msg is None: |
|
|||
143 | return |
|
|||
144 | else: |
|
|||
145 | idents,msg = msg |
|
|||
146 |
|
137 | |||
147 | # assert self.reply_socketly_socket.rcvmore(), "Unexpected missing message part." |
|
|||
148 | # msg = self.reply_socket.recv_json() |
|
|||
149 | self.log.info("Aborting:") |
|
138 | self.log.info("Aborting:") | |
150 | self.log.info(str(msg)) |
|
139 | self.log.info(str(msg)) | |
151 | msg_type = msg['msg_type'] |
|
140 | msg_type = msg['msg_type'] |
General Comments 0
You need to be logged in to leave comments.
Login now