Fix recv_requests (#2405)
This commit is contained in:
@@ -445,6 +445,7 @@ class Scheduler:
|
|||||||
recv_req = self.recv_from_tokenizer.recv_pyobj(zmq.NOBLOCK)
|
recv_req = self.recv_from_tokenizer.recv_pyobj(zmq.NOBLOCK)
|
||||||
except zmq.ZMQError:
|
except zmq.ZMQError:
|
||||||
break
|
break
|
||||||
|
recv_reqs.append(recv_req)
|
||||||
else:
|
else:
|
||||||
recv_reqs = None
|
recv_reqs = None
|
||||||
|
|
||||||
|
|||||||
Reference in New Issue
Block a user