mirror of
https://github.com/wassname/ray.git
synced 2026-07-11 23:42:33 +08:00
Use set comprehensions (#5707)
This commit is contained in:
@@ -101,9 +101,10 @@ class CentralizedQueues:
|
||||
|
||||
def _get_available_backends(self, service):
|
||||
backends_in_policy = set(self.traffic[service].keys())
|
||||
available_workers = set((backend
|
||||
for backend, queues in self.workers.items()
|
||||
if len(queues) > 0))
|
||||
available_workers = {
|
||||
backend
|
||||
for backend, queues in self.workers.items() if len(queues) > 0
|
||||
}
|
||||
return list(backends_in_policy.intersection(available_workers))
|
||||
|
||||
def _flush(self):
|
||||
|
||||
Reference in New Issue
Block a user