diff --git a/fastdeploy/cache_manager/cache_transfer_manager.py b/fastdeploy/cache_manager/cache_transfer_manager.py index 017bb2ebb8d..71143ce18e7 100644 --- a/fastdeploy/cache_manager/cache_transfer_manager.py +++ b/fastdeploy/cache_manager/cache_transfer_manager.py @@ -91,6 +91,13 @@ def parse_args(): default="{}", help="speculative config", ) + parser.add_argument( + "--default_dtype", + type=str, + default="bfloat16", + choices=["float16", "bfloat16", "uint8"], + help="paddle default dtype, swap_cache_batch only support float16、bfloat16 and uint8 now", + ) parser.add_argument("--local_data_parallel_id", type=int, default=0) args = parser.parse_args() @@ -119,6 +126,7 @@ def __init__(self, args): self.speculative_config = SpeculativeConfig(args.speculative_config) self.num_extra_layers = self.speculative_config.num_extra_cache_layer self.num_extra_layer_gpu_blocks = int(args.num_gpu_blocks * self.speculative_config.num_gpu_block_expand_ratio) + paddle.set_default_dtype(args.default_dtype) self.swap_to_cpu_thread_pool = concurrent.futures.ThreadPoolExecutor(max_workers=1) self.swap_to_gpu_thread_pool = concurrent.futures.ThreadPoolExecutor(max_workers=1) diff --git a/fastdeploy/cache_manager/prefix_cache_manager.py b/fastdeploy/cache_manager/prefix_cache_manager.py index c5a113ccb3a..bbdee86d742 100644 --- a/fastdeploy/cache_manager/prefix_cache_manager.py +++ b/fastdeploy/cache_manager/prefix_cache_manager.py @@ -64,6 +64,7 @@ def __init__( self.enable_splitwise = 0 self.splitwise_role = splitwise_role + self.config = config self.cache_config = config.cache_config self.speculative_config = config.speculative_config self.local_data_parallel_id = local_data_parallel_id @@ -203,6 +204,7 @@ def launch_cache_manager( + f" --local_data_parallel_id {self.local_data_parallel_id}" + f" --rdma_port {cache_config.rdma_comm_ports[i] if cache_config.rdma_comm_ports is not None else '0'}" + f" --speculative_config '{self.speculative_config.to_json_string()}'" + + f" --default_dtype '{self.config.model_config.dtype}'" + f" >{log_dir}/launch_cache_manager_{int(device_ids[i])}.log 2>&1" ) logger.info(f"Launch cache transfer manager, command:{launch_cmd}")