-
Type:
Build Failure
-
Resolution: Fixed
-
Priority:
Unknown
-
Affects Version/s: None
-
Component/s: None
-
None
-
Python Drivers
-
Not Needed
-
None
-
None
-
None
-
None
-
None
-
None
test_async_cancellation_closes_change_stream is flaky:
[2025/02/28 21:38:07.748] FAILURE: AssertionError: False is not true () [2025/02/28 21:38:07.748] self = <test.asynchronous.test_async_cancellation.TestAsyncCancellation testMethod=test_async_cancellation_closes_change_stream> [2025/02/28 21:38:07.748] @async_client_context.require_change_streams [2025/02/28 21:38:07.748] @async_client_context.require_failCommand_blockConnection [2025/02/28 21:38:07.748] async def test_async_cancellation_closes_change_stream(self): [2025/02/28 21:38:07.748] self.addAsyncCleanup(self.client.db.test.delete_many, {}) [2025/02/28 21:38:07.748] change_stream = await self.client.db.test.watch(batch_size=2) [2025/02/28 21:38:07.748] [2025/02/28 21:38:07.748] # Make sure getMore commands block [2025/02/28 21:38:07.748] fail_command = { [2025/02/28 21:38:07.748] "configureFailPoint": "failCommand", [2025/02/28 21:38:07.748] "mode": "alwaysOn", [2025/02/28 21:38:07.748] "data": {"failCommands": ["getMore"], "blockConnection": True, "blockTimeMS": 200}, [2025/02/28 21:38:07.748] } [2025/02/28 21:38:07.748] [2025/02/28 21:38:07.748] async def task(): [2025/02/28 21:38:07.748] async with self.fail_point(fail_command): [2025/02/28 21:38:07.748] await self.client.db.test.insert_many([{"x": 1}, {"x": 2}]) [2025/02/28 21:38:07.748] await change_stream.next() [2025/02/28 21:38:07.748] [2025/02/28 21:38:07.748] task = asyncio.create_task(task()) [2025/02/28 21:38:07.748] [2025/02/28 21:38:07.748] await asyncio.sleep(0.1) [2025/02/28 21:38:07.748] [2025/02/28 21:38:07.748] task.cancel() [2025/02/28 21:38:07.748] with self.assertRaises(asyncio.CancelledError): [2025/02/28 21:38:07.748] await task [2025/02/28 21:38:07.748] [2025/02/28 21:38:07.748] > self.assertTrue(change_stream._closed) [2025/02/28 21:38:07.748] E AssertionError: False is not true [2025/02/28 21:38:07.748] test/asynchronous/test_async_cancellation.py:126: AssertionError
When the cancel() happens when the task is in the insert_many, then tests fails because the change stream cursor will not have been closed.
- is caused by
-
PYTHON-4745 Document and Test Behavior when User Cancels Async Operation
-
- Closed
-
- is duplicated by
-
-
- Closed
-