From 10174e1114dc69a8764af527503223654abd47f7 Mon Sep 17 00:00:00 2001 From: Yuhao Yang <47235274+yhyang201@users.noreply.github.com> Date: Mon, 5 Jan 2026 14:05:39 +0800 Subject: [PATCH] Revert "[grpc] update api to scheduler in grpc request manager" (#16387) --- python/sglang/srt/grpc/grpc_request_manager.py | 5 +---- 1 file changed, 1 insertion(+), 4 deletions(-) diff --git a/python/sglang/srt/grpc/grpc_request_manager.py b/python/sglang/srt/grpc/grpc_request_manager.py index 89f32b3a1..cc1e9f64a 100644 --- a/python/sglang/srt/grpc/grpc_request_manager.py +++ b/python/sglang/srt/grpc/grpc_request_manager.py @@ -8,7 +8,6 @@ import copy import dataclasses import logging import os -import pickle import signal import sys import threading @@ -801,9 +800,7 @@ class GrpcRequestManager: async def _send_to_scheduler(self, obj): """Send an object to the scheduler via ZMQ.""" try: - self.send_to_scheduler.send_multipart( - [b"NORM", pickle.dumps(obj)], copy=False - ) + self.send_to_scheduler.send_pyobj(obj) except Exception as e: logger.error(f"Failed to send to scheduler: {e}") raise