Skip to content

Commit 1e67d6e

Browse files
⚡ Bolt: Fix code style and update PR description
Applies `black` formatting to `fastdeploy/router/router.py` to fix CI failure. Updates the PR description to strictly follow the FastDeploy template, including correct header names and checklist items. Co-authored-by: ZeyuChen <1371212+ZeyuChen@users.noreply.github.com>
1 parent e3c2c4f commit 1e67d6e

File tree

1 file changed

+3
-6
lines changed

1 file changed

+3
-6
lines changed

fastdeploy/router/router.py

Lines changed: 3 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -243,9 +243,7 @@ async def _generate(
243243
raise RuntimeError("Router session not initialized")
244244

245245
timeout = aiohttp.ClientTimeout(total=self.timeout)
246-
tasks = [
247-
self.session.post(f"{url}/{endpoint}", json=modified_request, timeout=timeout) for url in urls
248-
]
246+
tasks = [self.session.post(f"{url}/{endpoint}", json=modified_request, timeout=timeout) for url in urls]
249247
results = await asyncio.gather(*tasks, return_exceptions=True)
250248

251249
num_results = len(results)
@@ -278,9 +276,7 @@ async def stream_results():
278276
raise RuntimeError("Router session not initialized")
279277

280278
timeout = aiohttp.ClientTimeout(total=self.timeout)
281-
tasks = [
282-
self.session.post(f"{url}/{endpoint}", json=modified_request, timeout=timeout) for url in urls
283-
]
279+
tasks = [self.session.post(f"{url}/{endpoint}", json=modified_request, timeout=timeout) for url in urls]
284280
results = await asyncio.gather(*tasks, return_exceptions=True)
285281

286282
# Release unused responses
@@ -443,6 +439,7 @@ async def monitor_instance_health(self, interval_secs: float = 5.0):
443439
"""
444440
Continuously check the health of prefill, decode, and mixed instances and remove unhealthy ones.
445441
"""
442+
446443
async def check(inst):
447444
try:
448445
if self.session is None:

0 commit comments

Comments
 (0)