diff --git a/python/pipeline/channel.py b/python/pipeline/channel.py index 2763a814c6ad104a3d8dd371079424ffa158a538..ce55b187e66ae02916d04a57732391de01f4ece5 100644 --- a/python/pipeline/channel.py +++ b/python/pipeline/channel.py @@ -172,7 +172,6 @@ class ProcessChannel(multiprocessing.queues.Queue): self._cv = multiprocessing.Condition() - self._manager = manager self._producers = [] self._pushed_producer_count = manager.dict() # {data_id: count} self._input_buf = manager.dict() # {data_id: {op_name: data}}