diff --git a/python/pipeline/channel.py b/python/pipeline/channel.py index 1800dc923ab45afb05f96b21cd61e5b83f0084ce..5de1accf743d7908e9c862b5aa2375e41f66ccbb 100644 --- a/python/pipeline/channel.py +++ b/python/pipeline/channel.py @@ -329,13 +329,7 @@ class ProcessChannel(object): _LOGGER.debug( self._log("{} try to get(with channel empty: {})". format(op_name, self._que.empty()))) - # For queue multiprocess: after putting an object on - # an empty queue there may be an infinitessimal delay - # before the queue's :meth:`~Queue.empty` - # see more: - # - https://bugs.python.org/issue18277 - # - https://hg.python.org/cpython/rev/860fc6a2bd21 - resp = self._que.get(timeout=1e-3) + resp = self._que.get(timeout=0) break except Queue.Empty: _LOGGER.debug( @@ -376,7 +370,7 @@ class ProcessChannel(object): _LOGGER.debug( self._log("{} try to get(with channel size: {})".format( op_name, self._que.qsize()))) - channeldata = self._que.get(timeout=1e-3) + channeldata = self._que.get(timeout=0) self._output_buf.append(channeldata) break except Queue.Empty: