diff --git a/ipyparallel/engine/app.py b/ipyparallel/engine/app.py index 1aa394e5..640f5235 100755 --- a/ipyparallel/engine/app.py +++ b/ipyparallel/engine/app.py @@ -560,7 +560,7 @@ async def register(self): # wait for reply poller = zmq.asyncio.Poller() poller.register(reg, zmq.POLLIN) - events = dict(await poller.poll(timeout=self.timeout)) + events = dict(await poller.poll(timeout=int(self.timeout * 1_000))) if events: msg = reg.recv_multipart() try: