def get_data(self):
try:
for k in itertools.count():
if self._size > 0 and k >= self._size:
break
dp = loads(self.socket.recv(copy=False).bytes)
yield dp
except zmq.ContextTerminated:
logger.info("ContextTerminated in Master Prefetch Process")
return
except BaseException:
raise
评论列表
文章目录