Skip to content

Commit c0ef07f

Browse files
author
Andrei Neagu
committed
added addional test
1 parent dc8ef21 commit c0ef07f

File tree

1 file changed

+17
-0
lines changed

1 file changed

+17
-0
lines changed

packages/service-library/tests/long_running_interfaces/test_workflow.py

Lines changed: 17 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -60,6 +60,12 @@ async def raising_f() -> None:
6060
msg = "I always raise an error"
6161
raise RuntimeError(msg)
6262

63+
@registry.expose()
64+
async def raising_after_sleep_f(duration: float) -> None:
65+
await asyncio.sleep(duration)
66+
msg = "I always raise an error"
67+
raise RuntimeError(msg)
68+
6369
@registry.expose()
6470
async def sleep_forever_f() -> None:
6571
while True: # noqa: ASYNC110
@@ -129,6 +135,17 @@ async def test_timeout_error(server: Server, client: Client):
129135
)
130136

131137

138+
async def test_timeout_during_failing_retry(server: Server, client: Client):
139+
with pytest.raises(TimedOutError):
140+
await client.ensure_result(
141+
"raising_after_sleep_f",
142+
expected_type=type(None),
143+
timeout=timedelta(seconds=2),
144+
retry_count=100,
145+
duration=1,
146+
)
147+
148+
132149
@pytest.mark.parametrize("retry_count", [1, 2])
133150
async def test_stops_after_n_retry_attempts(
134151
server: Server, client: Client, retry_count: NonNegativeInt

0 commit comments

Comments
 (0)