30c22921d95bb66b6400c52fb19d640cbd0ee3e9,python/ray/serve/router.py,Router,_update_traffic_policies,#Router#Any#,192

Before Change

                traffic_policy)
            if endpoint in self._pending_endpoints:
                event = self._pending_endpoints.pop(endpoint)
                event.set()

    async def _update_replica_handles(self, replica_handles):
        for backend_tag, replica_handles in replica_handles.items():
            self.backend_replicas[backend_tag].update_worker_replicas(

After Change

                future.set_result(_PendingEndpointFound.ADDED)

        for endpoint, traffic_policy in removed.items():
            del self.endpoint_policies[endpoint]
            if endpoint in self._pending_endpoints:
                future = self._pending_endpoints.pop(endpoint)
                future.set_result(_PendingEndpointFound.REMOVED)

    async def _update_replica_handles(self, replica_handles):
        added, removed, updated = compute_dict_delta(self.backend_replicas,
                                                     replica_handles)

Instances