We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent e075f6c commit 68b69c8Copy full SHA for 68b69c8
1 file changed
src/sglang_diffusion_routing/router/diffusion_router.py
@@ -387,13 +387,11 @@ async def _broadcast_to_workers(
387
"""
388
if path == "resume_memory_occupation":
389
# Wake is a recovery point: allow waking workers that were marked dead during sleep.
390
- urls = [
391
- u for u in self.sleeping_workers
392
- if u in self.worker_request_counts
393
- ]
+ urls = [u for u in self.sleeping_workers if u in self.worker_request_counts]
394
else:
395
urls = [
396
- u for u in self.worker_request_counts
+ u
+ for u in self.worker_request_counts
397
if u not in self.dead_workers and u not in self.sleeping_workers
398
]
399
0 commit comments