Commit d04c8444 authored by Yuxin Wu's avatar Yuxin Wu

bugfix in ZMQInput

parent d8dd7ca9
...@@ -425,13 +425,14 @@ class ZMQInput(TensorInput): ...@@ -425,13 +425,14 @@ class ZMQInput(TensorInput):
def fn(): def fn():
ret = self._zmq_pull_socket.pull() ret = self._zmq_pull_socket.pull()
assert len(ret) == len(self._desc) assert len(ret) == len(self._spec)
for qv, v in zip(ret, self._desc): for qv, v in zip(ret, self._spec):
qv.set_shape(v.shape) qv.set_shape(v.shape)
return ret return ret
super(ZMQInput, self).__init__(fn) super(ZMQInput, self).__init__(fn)
def _setup(self, input_signature): def _setup(self, input_signature):
super(ZMQInput, self)._setup(input_signature)
assert len(input_signature) > 0, \ assert len(input_signature) > 0, \
"ZMQInput has to be used with input signature!" "ZMQInput has to be used with input signature!"
......
...@@ -228,7 +228,7 @@ def collect_env_info(): ...@@ -228,7 +228,7 @@ def collect_env_info():
has_prctl = True has_prctl = True
try: try:
import prctl import prctl
_ = prctl.set_pdeathsig _ = prctl.set_pdeathsig # noqa
except Exception: except Exception:
has_prctl = False has_prctl = False
data.append(("python-prctl", has_prctl)) data.append(("python-prctl", has_prctl))
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment