diff --git a/fastdeploy/engine/common_engine.py b/fastdeploy/engine/common_engine.py index d574f77be..99ec5e846 100644 --- a/fastdeploy/engine/common_engine.py +++ b/fastdeploy/engine/common_engine.py @@ -1148,7 +1148,7 @@ class EngineService: def _zmq_send_generated_tokens(self): """ - Recieve output for zmq + Receive output for zmq """ while self.running: try: diff --git a/fastdeploy/inter_communicator/zmq_server.py b/fastdeploy/inter_communicator/zmq_server.py index f24fe0674..79528c5a0 100644 --- a/fastdeploy/inter_communicator/zmq_server.py +++ b/fastdeploy/inter_communicator/zmq_server.py @@ -414,7 +414,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 4da49a966..3ee395316 100644 --- a/fastdeploy/metrics/metrics.py +++ b/fastdeploy/metrics/metrics.py @@ -472,13 +472,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/metrics/trace.py b/fastdeploy/metrics/trace.py index 5c60b4e98..39865dc10 100644 --- a/fastdeploy/metrics/trace.py +++ b/fastdeploy/metrics/trace.py @@ -270,7 +270,7 @@ def process_tracing_init(): # ) trace.set_tracer_provider(tracer_provider) except Exception as e: - logger.error(f": initialize opentelemetry error:{e}") + logger.error(f"Initialize opentelemetry error: {e}") logger.warning("please set correct otlp endpoint") tracing_enabled = False return @@ -628,7 +628,7 @@ def trace_slice_end( thread_context = reqs_context[rid].threads_context[pid] if not thread_context.cur_slice_stack: - logger.warning(f"No matching with the SLICE_START event{name} is required.") + logger.warning(f"No matching SLICE_START event for {name} is required.") return ts = ts or __get_cur_time_ns() diff --git a/fastdeploy/output/token_processor.py b/fastdeploy/output/token_processor.py index f5aeb7277..ad1ba0b8f 100644 --- a/fastdeploy/output/token_processor.py +++ b/fastdeploy/output/token_processor.py @@ -355,7 +355,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 error: {e}") + llm_logger.error(f"Receive message error: {e}") continue def process_sampling_results(self): diff --git a/fastdeploy/scheduler/dp_scheduler.py b/fastdeploy/scheduler/dp_scheduler.py index 05ee40487..3c1af6b31 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[self.dp_rank].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 576a3717f..5c2f793fd 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()