From 3a85ecf3bcab2de0732ecce47af1b7fc0836fbe9 Mon Sep 17 00:00:00 2001 From: 1 <1@cloudforge.solutions> Date: Mon, 9 Mar 2026 10:26:25 +0800 Subject: [PATCH] [Others] Fix typos in log messages and comments (#6707) Fix spelling errors in log messages, docstrings, and comments: - 'occured' -> 'occurred' (8 instances) - 'Recieve'/'recieved' -> 'Receive'/'received' (7 instances) - 'happend' -> 'happened' (3 instances) - 'expet_servic' -> 'expert_service' (2 instances) - 'meas' -> 'means' (1 instance) No functional changes. Only log strings, docstrings, and comments are affected. Co-authored-by: cloudforge1 --- fastdeploy/cache_manager/cache_messager.py | 2 +- fastdeploy/cache_manager/prefix_cache_manager.py | 14 +++++++------- fastdeploy/engine/common_engine.py | 8 ++++---- fastdeploy/engine/engine.py | 2 +- fastdeploy/inter_communicator/zmq_server.py | 2 +- fastdeploy/metrics/metrics.py | 4 ++-- fastdeploy/output/token_processor.py | 4 ++-- fastdeploy/scheduler/dp_scheduler.py | 2 +- fastdeploy/splitwise/internal_adapter_utils.py | 2 +- 9 files changed, 20 insertions(+), 20 deletions(-) diff --git a/fastdeploy/cache_manager/cache_messager.py b/fastdeploy/cache_manager/cache_messager.py index d91e626ea5..e1e093e201 100644 --- a/fastdeploy/cache_manager/cache_messager.py +++ b/fastdeploy/cache_manager/cache_messager.py @@ -671,7 +671,7 @@ class CacheMessagerV1: else: time.sleep(0.001) except Exception as e: - logger.info(f"add cache task occured error: {e}, {traceback.format_exc()!s}.") + logger.info(f"add cache task occurred error: {e}, {traceback.format_exc()!s}.") def prefill_layerwise_send_cache_thread(self): """ diff --git a/fastdeploy/cache_manager/prefix_cache_manager.py b/fastdeploy/cache_manager/prefix_cache_manager.py index 700df897b7..60f295ca8a 100644 --- a/fastdeploy/cache_manager/prefix_cache_manager.py +++ b/fastdeploy/cache_manager/prefix_cache_manager.py @@ -719,7 +719,7 @@ class PrefixCacheManager: except Exception as e: if self.prefix_tree_status_signal.value[0] != PrefixTreeStatus.NORMAL: logger.warning( - f"update_cache_blocks: an error occured while prefix tree status is not normal, ignore it. {e}" + f"update_cache_blocks: an error occurred while prefix tree status is not normal, ignore it. {e}" ) else: logger.error(f"update_cache_blocks, error: {type(e)} {e}, {str(traceback.format_exc())}") @@ -907,7 +907,7 @@ class PrefixCacheManager: except Exception as e: if self.prefix_tree_status_signal.value[0] != PrefixTreeStatus.NORMAL: logger.warning( - f"request_match_blocks: an error occured while prefix tree status is not normal, ignore it. {e}" + f"request_match_blocks: an error occurred while prefix tree status is not normal, ignore it. {e}" ) else: logger.error(f"request_match_blocks: request_block_ids: error: {type(e)} {e}") @@ -1014,7 +1014,7 @@ class PrefixCacheManager: except Exception as e: if self.prefix_tree_status_signal.value[0] != PrefixTreeStatus.NORMAL: logger.warning( - f"request_block_ids: an error occured while prefix tree status is not normal, ignore it. {e}" + f"request_block_ids: an error occurred while prefix tree status is not normal, ignore it. {e}" ) else: logger.error(f"request_block_ids: error: {type(e)} {e}, {str(traceback.format_exc())}") @@ -1075,7 +1075,7 @@ class PrefixCacheManager: except Exception as e: if self.prefix_tree_status_signal.value[0] != PrefixTreeStatus.NORMAL: logger.warning( - f"release_block_ids: an error occured while prefix tree status is not normal, ignore it. {e}" + f"release_block_ids: an error occurred while prefix tree status is not normal, ignore it. {e}" ) else: logger.error(f"release_block_ids: error: {type(e)} {e}, {str(traceback.format_exc())}") @@ -1205,7 +1205,7 @@ class PrefixCacheManager: except Exception as e: if self.prefix_tree_status_signal.value[0] != PrefixTreeStatus.NORMAL: logger.warning( - f"free_nodes_directly: an error occured while prefix tree status is not normal, ignore it. {e}" + f"free_nodes_directly: an error occurred while prefix tree status is not normal, ignore it. {e}" ) else: logger.error(f"free_nodes_directly: error: {type(e)} {e}") @@ -1403,7 +1403,7 @@ class PrefixCacheManager: except Exception as e: if self.prefix_tree_status_signal.value[0] != PrefixTreeStatus.NORMAL: logger.warning( - f"free_block_ids_async: an error occured while prefix tree status is not normal, ignore it. {e}" + f"free_block_ids_async: an error occurred while prefix tree status is not normal, ignore it. {e}" ) else: logger.error(f"free_block_ids_async: error: {type(e)} {e}, {str(traceback.format_exc())}") @@ -2081,7 +2081,7 @@ class PrefixCacheManager: except Exception as e: if self.prefix_tree_status_signal.value[0] != PrefixTreeStatus.NORMAL: logger.warning( - f"recv_data_transfer_result: an error occured while prefix tree status is not normal, ignore it. {e}" + f"recv_data_transfer_result: an error occurred while prefix tree status is not normal, ignore it. {e}" ) else: logger.error(f"recv_data_transfer_result: {str(traceback.format_exc())}") diff --git a/fastdeploy/engine/common_engine.py b/fastdeploy/engine/common_engine.py index 6398b03ea1..5723a23937 100644 --- a/fastdeploy/engine/common_engine.py +++ b/fastdeploy/engine/common_engine.py @@ -797,7 +797,7 @@ class EngineService: main_process_metrics.num_requests_waiting.dec(len(tasks)) main_process_metrics.num_requests_running.inc(len(tasks)) except Exception as e: - err_msg = f"Error happend while insert task to engine: {e}, {traceback.format_exc()!s}." + err_msg = f"Error happened while insert task to engine: {e}, {traceback.format_exc()!s}." self.llm_logger.error(err_msg) def _schedule_request_to_worker_v1(self): @@ -1076,7 +1076,7 @@ class EngineService: if "cannot schedule new futures after shutdown" in str(e): break except Exception as e: - err_msg = "Error happend while insert task to engine: {}, {}.".format(e, str(traceback.format_exc())) + err_msg = "Error happened while insert task to engine: {}, {}.".format(e, str(traceback.format_exc())) self.llm_logger.error(err_msg) def _get_scheduler_unhandled_request_num(self) -> int: @@ -1466,7 +1466,7 @@ class EngineService: def _zmq_send_generated_tokens(self): """ - Recieve output for zmq + Receive output for zmq """ while self.running: try: @@ -1860,7 +1860,7 @@ class EngineService: create=True, ) - # launched_expert_service_signal: Used to sense whether each expet_servic is started successfully + # launched_expert_service_signal: Used to sense whether each expert_service is started successfully if self.cfg.parallel_config.enable_expert_parallel and self.cfg.parallel_config.data_parallel_size > 1: launched_expert_service_signal_data = np.zeros( shape=[self.cfg.parallel_config.data_parallel_size // self.cfg.nnode], dtype=np.int32 diff --git a/fastdeploy/engine/engine.py b/fastdeploy/engine/engine.py index b09956fb80..790365482c 100644 --- a/fastdeploy/engine/engine.py +++ b/fastdeploy/engine/engine.py @@ -376,7 +376,7 @@ class LLMEngine: create=True, ) - # launched_expert_service_signal: Used to sense whether each expet_servic is started successfully + # launched_expert_service_signal: Used to sense whether each expert_service is started successfully if self.cfg.parallel_config.data_parallel_size > 1 and not envs.FD_ENABLE_MULTI_API_SERVER: launched_expert_service_signal_data = np.zeros( shape=[self.cfg.parallel_config.data_parallel_size // self.cfg.nnode], dtype=np.int32 diff --git a/fastdeploy/inter_communicator/zmq_server.py b/fastdeploy/inter_communicator/zmq_server.py index c5b424416b..913991a48b 100644 --- a/fastdeploy/inter_communicator/zmq_server.py +++ b/fastdeploy/inter_communicator/zmq_server.py @@ -420,7 +420,7 @@ class ZmqTcpServer(ZmqServerBase): def recv_control_cmd(self): """ - Recieve control command from client + Receive control command from client """ self._ensure_socket() try: diff --git a/fastdeploy/metrics/metrics.py b/fastdeploy/metrics/metrics.py index 2384e57c7b..8c15e26318 100644 --- a/fastdeploy/metrics/metrics.py +++ b/fastdeploy/metrics/metrics.py @@ -480,13 +480,13 @@ class MetricsManager: "msg_recv_total": { "type": Counter, "name": "fastdeploy:zmq:msg_recv_total", - "description": "Total number of zmq messages recieved", + "description": "Total number of zmq messages received", "kwargs": {"labelnames": ["address"]}, }, "msg_bytes_recv_total": { "type": Counter, "name": "fastdeploy:zmq:msg_bytes_recv_total", - "description": "Total number of bytes recieved over zmq", + "description": "Total number of bytes received over zmq", "kwargs": {"labelnames": ["address"]}, }, "zmq_latency": { diff --git a/fastdeploy/output/token_processor.py b/fastdeploy/output/token_processor.py index c52bfecc0b..89b767f9ed 100644 --- a/fastdeploy/output/token_processor.py +++ b/fastdeploy/output/token_processor.py @@ -393,7 +393,7 @@ class TokenProcessor: batch_result = self._process_batch_output_use_zmq(receive_datas) self.postprocess(batch_result) except Exception as e: - llm_logger.error(f"Recieve message:{receive_datas}, error:{e}") + llm_logger.error(f"Receive message:{receive_datas}, error:{e}") continue def process_sampling_results(self): @@ -753,7 +753,7 @@ class TokenProcessor: tracing.trace_set_proc_propagate_context(rid, trace_carrier, ts) if self.cfg.speculative_config.method: self._record_speculative_decoding_accept_num_per_request(task_id, accept_num[i]) - if accept_num[i] == PREEMPTED_TOKEN_ID: # in MTP, meas preemption has happend in worker + if accept_num[i] == PREEMPTED_TOKEN_ID: # in MTP, means preemption has happened in worker llm_logger.info(f"sync preemption for request_id {task_id} done.") if envs.ENABLE_V1_KVCACHE_SCHEDULER: if task_id in self.resource_manager.abort_req_ids_set: diff --git a/fastdeploy/scheduler/dp_scheduler.py b/fastdeploy/scheduler/dp_scheduler.py index 72dc610106..f5b03eba30 100644 --- a/fastdeploy/scheduler/dp_scheduler.py +++ b/fastdeploy/scheduler/dp_scheduler.py @@ -228,7 +228,7 @@ class DPScheduler: def _put_requests_to_local(self): while True: request = self.request_queues.get() - self.scheduler_logger.info(f"Recieve request from puller, request_id: {request.request_id}") + self.scheduler_logger.info(f"Receive request from puller, request_id: {request.request_id}") self._scheduler.put_requests([request]) def _get_response_from_local(self): diff --git a/fastdeploy/splitwise/internal_adapter_utils.py b/fastdeploy/splitwise/internal_adapter_utils.py index 576a3717fe..5c2f793fdb 100644 --- a/fastdeploy/splitwise/internal_adapter_utils.py +++ b/fastdeploy/splitwise/internal_adapter_utils.py @@ -78,7 +78,7 @@ class InternalAdapter: if task is None: time.sleep(0.001) continue - logger.info(f"dprank {self.dp_rank} Recieve control task: {task}") + logger.info(f"dprank {self.dp_rank} Receive control task: {task}") task_id_str = task["task_id"] if task["cmd"] == "get_payload": payload_info = self._get_current_server_info()