修复代码中的日志错误消息：拼写和语法问题

Co-authored-by: Jiang-Jia-Jun <163579578+Jiang-Jia-Jun@users.noreply.github.com>

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:

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:

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": {

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()

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):

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):

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()