python · gvanrossum · Jul 2, 2021 · Sep 24, 2019 · Sep 25, 2019 · Dec 12, 2017
@@ -958,7 +958,7 @@ def MakeProxyType(name, exposed, _cache={}):


 def AutoProxy(token, serializer, manager=None, authkey=None,
-              exposed=None, incref=True):
+              exposed=None, incref=True, manager_owned=False):
    '''
    Return an auto-proxy for `token`
    '''
@@ -978,7 +978,7 @@ def AutoProxy(token, serializer, manager=None, authkey=None,

    ProxyType = MakeProxyType('AutoProxy[%s]' % token.typeid, exposed)
    proxy = ProxyType(token, serializer, manager=manager, authkey=authkey,
-                      incref=incref)
+                      incref=incref, manager_owned=manager_owned)
    proxy._isauto = True
    return proxy


@@ -2256,6 +2256,16 @@ def test_dict_proxy_nested(self):
        self.assertIsInstance(outer[0], list)  # Not a ListProxy
        self.assertEqual(outer[-1][-1]['feed'], 3)

+    def test_nested_queue(self):
+        a = self.list() # Test queue inside list
+        a.append(self.Queue())
+        a[0].put(123)
+        self.assertEqual(a[0].get(), 123)
+        b = self.dict() # Test queue inside dict
+        b[0] = self.Queue()
+        b[0].put(456)
+        self.assertEqual(b[0].get(), 456)
+
    def test_namespace(self):
        n = self.Namespace()
        n.name = 'Bob'

diff --git a/Misc/NEWS.d/next/Library/2019-09-25-13-54-41.bpo-30256.wBkzox.rst b/Misc/NEWS.d/next/Library/2019-09-25-13-54-41.bpo-30256.wBkzox.rst
@@ -0,0 +1 @@
+Pass multiprocessing BaseProxy argument `manager_owned` through AutoProxy
diff --git a/Misc/NEWS.d/next/Tests/2019-09-25-18-10-10.bpo-30256.A5i76Q.rst b/Misc/NEWS.d/next/Tests/2019-09-25-18-10-10.bpo-30256.A5i76Q.rst
@@ -0,0 +1,2 @@
+Add test for nested queues when using ``multiprocessing`` shared objects
+``AutoProxy[Queue]`` inside ``ListProxy`` and ``DictProxy``
Original file line number	Diff line number	Diff line change
		@@ -0,0 +1 @@
		Pass multiprocessing BaseProxy argument `manager_owned` through AutoProxy
Original file line number	Diff line number	Diff line change
		@@ -0,0 +1,2 @@
		Add test for nested queues when using ``multiprocessing`` shared objects
		``AutoProxy[Queue]`` inside ``ListProxy`` and ``DictProxy``