I needed to make these small changes in order to get queue working with my multiprocessing code in python 3.6+.
There were two issues:
multiprocessing.queues.Queue.__init__ takes a ctx argument, which was not provided
if you are using spawn rather than fork with multiprocessing (e.g. running on Windows), _size doesn't get pickled, and get/put/etc will throw an AttributeError about there being no such attribute
I needed to make these small changes in order to get queue working with my multiprocessing code in python 3.6+.
There were two issues:
multiprocessing.queues.Queue.__init__
takes actx
argument, which was not provided_size
doesn't get pickled, and get/put/etc will throw an AttributeError about there being no such attribute