File tree Expand file tree Collapse file tree 1 file changed +9
-2
lines changed Expand file tree Collapse file tree 1 file changed +9
-2
lines changed Original file line number Diff line number Diff line change @@ -804,8 +804,15 @@ def configure_handler(self, config):
804
804
# if it's not an instance of BaseProxy, it also can't be
805
805
# an instance of Manager.Queue / Manager.JoinableQueue
806
806
if isinstance (qspec , BaseProxy ):
807
- proxy_queue = MM ().Queue ()
808
- proxy_joinable_queue = MM ().JoinableQueue ()
807
+ # Sometimes manager or queue creation might fail
808
+ # (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 ()
809
816
if not isinstance (qspec , (type (proxy_queue ), type (proxy_joinable_queue ))):
810
817
raise TypeError ('Invalid queue specifier %r' % qspec )
811
818
else :
You can’t perform that action at this time.
0 commit comments