fix: re-enable send message stress tests#1230
Draft
cartertinney wants to merge 1 commit into
Draft
Azure Pipelines / python-nightly
failed
May 12, 2026 in 1h 13m 13s
Build #158788_python-nightly_ct-misc-stress had test failures
Details
- Failed: 2 (3.92%, 2 new, 0 recurring)
- Passed: 39 (76.47%)
- Other: 10 (19.61%)
- Total: 51
Annotations
Check failure on line 478 in Build log
azure-pipelines / python-nightly
Build log #L478
Cmd.exe exited with code '1'.
Check failure on line 485 in Build log
azure-pipelines / python-nightly
Build log #L485
Cmd.exe exited with code '1'.
azure-pipelines / python-nightly
test_stress_send_message_with_flaky_network[auto_connect enabled-connection_retry disabled]
Failed: Timeout (>600.0s) from pytest-timeout.
Raw output
self = <Coroutine test_stress_send_message_with_flaky_network[auto_connect enabled-connection_retry disabled]>
def runtest(self) -> None:
runner_fixture_id = f"_{self._loop_scope}_scoped_runner"
runner = self._request.getfixturevalue(runner_fixture_id)
context = contextvars.copy_context()
synchronized_obj = _synchronize_coroutine(
getattr(*self._synchronization_target_attr), runner, context
)
with MonkeyPatch.context() as c:
c.setattr(*self._synchronization_target_attr, synchronized_obj)
> super().runtest()
/opt/hostedtoolcache/Python/3.12.13/x64/lib/python3.12/site-packages/pytest_asyncio/plugin.py:469:
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _
/opt/hostedtoolcache/Python/3.12.13/x64/lib/python3.12/site-packages/pytest_asyncio/plugin.py:716: in inner
runner.run(coro, context=context)
/opt/hostedtoolcache/Python/3.12.13/x64/lib/python3.12/asyncio/runners.py:118: in run
return self._loop.run_until_complete(task)
^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
/opt/hostedtoolcache/Python/3.12.13/x64/lib/python3.12/asyncio/base_events.py:678: in run_until_complete
self.run_forever()
/opt/hostedtoolcache/Python/3.12.13/x64/lib/python3.12/asyncio/base_events.py:645: in run_forever
self._run_once()
/opt/hostedtoolcache/Python/3.12.13/x64/lib/python3.12/asyncio/base_events.py:1961: in _run_once
event_list = self._selector.select(timeout)
^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _
self = <selectors.EpollSelector object at 0x7f3efce49b50>, timeout = 0.127
def select(self, timeout=None):
if timeout is None:
timeout = -1
elif timeout <= 0:
timeout = 0
else:
# epoll_wait() has a resolution of 1 millisecond, round away
# from zero to wait *at least* timeout seconds.
timeout = math.ceil(timeout * 1e3) * 1e-3
# epoll_wait() expects `maxevents` to be greater than zero;
# we want to make sure that `select()` can be called when no
# FD is registered.
max_ev = max(len(self._fd_to_key), 1)
ready = []
try:
> fd_event_list = self._selector.poll(timeout, max_ev)
^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
E Failed: Timeout (>600.0s) from pytest-timeout.
/opt/hostedtoolcache/Python/3.12.13/x64/lib/python3.12/selectors.py:468: Failed
azure-pipelines / python-nightly
test_stress_send_message_with_flaky_network[auto_connect disabled-connection_retry enabled]
Failed: Timeout (>600.0s) from pytest-timeout.
Raw output
self = <Coroutine test_stress_send_message_with_flaky_network[auto_connect disabled-connection_retry enabled]>
def runtest(self) -> None:
runner_fixture_id = f"_{self._loop_scope}_scoped_runner"
runner = self._request.getfixturevalue(runner_fixture_id)
context = contextvars.copy_context()
synchronized_obj = _synchronize_coroutine(
getattr(*self._synchronization_target_attr), runner, context
)
with MonkeyPatch.context() as c:
c.setattr(*self._synchronization_target_attr, synchronized_obj)
> super().runtest()
/opt/hostedtoolcache/Python/3.12.13/x64/lib/python3.12/site-packages/pytest_asyncio/plugin.py:469:
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _
/opt/hostedtoolcache/Python/3.12.13/x64/lib/python3.12/site-packages/pytest_asyncio/plugin.py:716: in inner
runner.run(coro, context=context)
/opt/hostedtoolcache/Python/3.12.13/x64/lib/python3.12/asyncio/runners.py:118: in run
return self._loop.run_until_complete(task)
^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
/opt/hostedtoolcache/Python/3.12.13/x64/lib/python3.12/asyncio/base_events.py:678: in run_until_complete
self.run_forever()
/opt/hostedtoolcache/Python/3.12.13/x64/lib/python3.12/asyncio/base_events.py:645: in run_forever
self._run_once()
/opt/hostedtoolcache/Python/3.12.13/x64/lib/python3.12/asyncio/base_events.py:1961: in _run_once
event_list = self._selector.select(timeout)
^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _
self = <selectors.EpollSelector object at 0x7f3efd629040>, timeout = 4.999
def select(self, timeout=None):
if timeout is None:
timeout = -1
elif timeout <= 0:
timeout = 0
else:
# epoll_wait() has a resolution of 1 millisecond, round away
# from zero to wait *at least* timeout seconds.
timeout = math.ceil(timeout * 1e3) * 1e-3
# epoll_wait() expects `maxevents` to be greater than zero;
# we want to make sure that `select()` can be called when no
# FD is registered.
max_ev = max(len(self._fd_to_key), 1)
ready = []
try:
> fd_event_list = self._selector.poll(timeout, max_ev)
^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
E Failed: Timeout (>600.0s) from pytest-timeout.
/opt/hostedtoolcache/Python/3.12.13/x64/lib/python3.12/selectors.py:468: Failed
Loading