bb494a3be8387467d892f10a8dbba4d2e1a68a3b,python/ray/serve/policy.py,FixedPackingPolicyQueue,__init__,#FixedPackingPolicyQueue#Any#,142

Before Change

    async def __init__(self, packing_num=3):
        // Saves the information about last assigned
        // backend for every endpoint
        self.fixed_packing_iterator_map = {}
        self.packing_num = packing_num
        await super().__init__()

    async def set_traffic(self, endpoint, traffic_dict):

After Change

    

    def __init__(self, traffic_dict):
        self.backend_names = list(traffic_dict.keys())
        self.backend_weights = list(traffic_dict.values())

    async def flush(self, endpoint_queue, backend_queues):
        if len(self.backend_names) == 0:

Instances