There was an error while loading. Please reload this page.
1 parent ccc0060 commit 6daf85eCopy full SHA for 6daf85e
1 file changed
Lib/logging/config.py
@@ -804,8 +804,15 @@ def configure_handler(self, config):
804
# if it's not an instance of BaseProxy, it also can't be
805
# an instance of Manager.Queue / Manager.JoinableQueue
806
if isinstance(qspec, BaseProxy):
807
- proxy_queue = MM().Queue()
808
- proxy_joinable_queue = MM().JoinableQueue()
+ # Sometimes manager or queue creation might fail
+ # (e.g. see issue gh-120868). In that case, any
809
+ # exception during the creation of these queues will
810
+ # propagate up to the caller and be wrapped in a
811
+ # `ValueError`, whose cause will indicate the details of
812
+ # the failure.
813
+ mm = MM()
814
+ proxy_queue = mm.Queue()
815
+ proxy_joinable_queue = mm.JoinableQueue()
816
if not isinstance(qspec, (type(proxy_queue), type(proxy_joinable_queue))):
817
raise TypeError('Invalid queue specifier %r' % qspec)
818
else:
0 commit comments