Uploaded image for project: 'Python Driver'
  1. Python Driver
  2. PYTHON-5176

Async cancellation tests are flakey on macos

XMLWordPrintableJSON

    • Type: Icon: Build Failure Build Failure
    • Resolution: Duplicate
    • Priority: Icon: Unknown Unknown
    • None
    • Affects Version/s: None
    • Component/s: None
    • None
    • Python Drivers
    • Hide

      1. What would you like to communicate to the user about this feature?
      2. Would you like the user to see examples of the syntax and/or executable code and its output?
      3. Which versions of the driver/connector does this apply to?

      Show
      1. What would you like to communicate to the user about this feature? 2. Would you like the user to see examples of the syntax and/or executable code and its output? 3. Which versions of the driver/connector does this apply to?
    • None
    • None
    • None
    • None
    • None
    • None

      Name of Failure:

      test.asynchronous.test_async_cancellation.TestAsyncCancellation.test_async_cancellation_closes_change_stream

      Link to task:

      https://spruce.mongodb.com/task/mongo_python_driver_test_macos_python3.9_test_5.0_sharded_cluster_auth_ssl_async_patch_c9a85ad321f98caf314fc9da7a367e94d661abac_67c249ed3639420007143c72_25_02_28_23_42_38?execution=0&sortBy=STATUS&sortDir=ASC

      Context of when and why the failure occurred:

      Async test failure.

      Stack trace:

       [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

            Assignee:
            Unassigned Unassigned
            Reporter:
            noah.stapp@mongodb.com Noah Stapp
            Votes:
            0 Vote for this issue
            Watchers:
            1 Start watching this issue

              Created:
              Updated:
              Resolved:
              None
              None
              None
              None