iomgaa/PolyGateway
1
0
Fork 0
Code Issues 3 Pull Requests Actions Packages Projects Releases 9 Wiki Activity

style: run the formatter over the issue 14 changes

Browse Source 
ruff format only; no semantic change.
This commit is contained in:
iomgaa
2026-08-20 00:44:21 -04:00
parent d9ceaecf20
commit 5a025b6e5d
5 changed files with 38 additions and 20 deletions
Download Patch File Download Diff File Expand all files Collapse all files
tests/unit/test_backpressure.py
+35 -10
View File
@@ -628,8 +628,12 @@ class TestCircuitOpenPolicy:
clock = FakeClock()
src = make_source()
mw = _mw(
[src], self._free_limiter(clock, src), [], clock=clock,
sleep=BoundedSleep(), gate=await self._opened_gate(clock),
[src],
self._free_limiter(clock, src),
[],
clock=clock,
sleep=BoundedSleep(),
gate=await self._opened_gate(clock),
)
with pytest.raises(CircuitOpenError) as ei:
await mw(_REQ)
@@ -650,8 +654,13 @@ class TestCircuitOpenPolicy:
sleep._side_effect = advance
mw = _mw(
[src], self._free_limiter(clock, src), [_ok()], clock=clock,
sleep=sleep, gate=await self._opened_gate(clock), circuit_open="wait",
[src],
self._free_limiter(clock, src),
[_ok()],
clock=clock,
sleep=sleep,
gate=await self._opened_gate(clock),
circuit_open="wait",
)
resp = await mw(_REQ)
assert resp.content == "ok"
@@ -671,8 +680,14 @@ class TestCircuitOpenPolicy:
sleep._side_effect = advance
mw = _mw(
[src], self._free_limiter(clock, src), [_ok()], clock=clock, sleep=sleep,
gate=await self._opened_gate(clock), quota_full="fail_fast", circuit_open="wait",
[src],
self._free_limiter(clock, src),
[_ok()],
clock=clock,
sleep=sleep,
gate=await self._opened_gate(clock),
quota_full="fail_fast",
circuit_open="wait",
)
assert (await mw(_REQ)).content == "ok"
@@ -694,8 +709,13 @@ class TestCircuitOpenPolicy:
sleep._side_effect = advance
mw = _mw(
[src], self._free_limiter(clock, src), [], clock=clock, sleep=sleep,
gate=await self._opened_gate(clock, long_cooldown), circuit_open="wait",
[src],
self._free_limiter(clock, src),
[],
clock=clock,
sleep=sleep,
gate=await self._opened_gate(clock, long_cooldown),
circuit_open="wait",
)
with pytest.raises(AllSourcesExhausted) as ei:
await mw(_REQ)
@@ -708,8 +728,13 @@ class TestCircuitOpenPolicy:
clock = FakeClock()
src = make_source()
mw = _mw(
[src], self._free_limiter(clock, src), [], clock=clock,
sleep=asyncio.sleep, gate=await self._opened_gate(clock), circuit_open="wait",
[src],
self._free_limiter(clock, src),
[],
clock=clock,
sleep=asyncio.sleep,
gate=await self._opened_gate(clock),
circuit_open="wait",
)
task = asyncio.create_task(mw(_REQ))
await asyncio.sleep(0.03)