bpo-45416: Fix use of asyncio.Condition() with explicit Lock objects

Lib/asyncio/locks.py

@@ -230,8 +230,6 @@ def __init__(self, lock=None, *, loop=mixins._marker):
         super().__init__(loop=loop)
         if lock is None:
             lock = Lock()
-        elif lock._loop is not self._get_loop():
-            raise ValueError("loop argument must agree with lock")
 
         self._lock = lock
         # Export the lock's locked(), acquire() and release() methods.

Lib/test/test_asyncio/test_locks.py

@@ -720,24 +720,39 @@ async def f():
         self.loop.run_until_complete(f())
 
     def test_explicit_lock(self):
-        lock = asyncio.Lock()
-        cond = asyncio.Condition(lock)
+        async def f():
+            lock = asyncio.Lock()
+            cond = asyncio.Condition(lock)
+            self.assertIs(cond._lock, lock)
+            # should work same!
+            self.assertFalse(cond.locked())
+            async with cond:
+                self.assertTrue(cond.locked())
+            self.assertFalse(cond.locked())
 
-        self.assertIs(cond._lock, lock)
-        self.assertIs(cond._loop, lock._loop)
+        self.loop.run_until_complete(f())
 
     def test_ambiguous_loops(self):
-        loop = self.new_test_loop()
-        self.addCleanup(loop.close)
-
         lock = asyncio.Lock()
+        loop = asyncio.new_event_loop()
+        self.addCleanup(loop.close)
         lock._loop = loop
 
-        async def _create_condition():
-            with self.assertRaises(ValueError):
-                asyncio.Condition(lock)
+        async def f():
+            async with lock:
+                # acquired immediately via the fast-path
+                # without interaction with any event loop.
+                cond = asyncio.Condition(lock)
+                # cond will trigger waiting on the lock
+                # and it will discover the event loop mismatch.
+                with self.assertRaisesRegex(
+                    RuntimeError,
+                    "is bound to a different event loop",
+                ):
+                    async with cond:
+                        pass
 
-        self.loop.run_until_complete(_create_condition())
+        self.loop.run_until_complete(f())
 
     def test_timeout_in_block(self):
         loop = asyncio.new_event_loop()

Misc/NEWS.d/next/Library/2021-10-10-09-42-34.bpo-45416.n35O0_.rst

@@ -0,0 +1,2 @@
+Fix use of :class:`asyncio.Condition` with explicit :class:`asyncio.Lock` objects, which was a regression due to removal of explicit loop arguments.
+Patch by Joongi Kim.