From 800fcf16dbc9425507553f44c3f0ce0b4ea025a8 Mon Sep 17 00:00:00 2001 From: s5u13b Date: Thu, 10 Oct 2024 10:26:03 +0000 Subject: [PATCH] Pylint --- llumnix/queue/queue_client_base.py | 2 +- llumnix/queue/ray_queue_client.py | 2 +- llumnix/queue/zmq_client.py | 2 +- 3 files changed, 3 insertions(+), 3 deletions(-) diff --git a/llumnix/queue/queue_client_base.py b/llumnix/queue/queue_client_base.py index dd908c1e..9e2c52c8 100644 --- a/llumnix/queue/queue_client_base.py +++ b/llumnix/queue/queue_client_base.py @@ -21,7 +21,7 @@ class QueueClientBase(ABC): @abstractmethod async def put_nowait(self, item: Any, server_info: ServerInfo): raise NotImplementedError - + @abstractmethod async def put_nowait_batch(self, items: Iterable, server_info: ServerInfo): raise NotImplementedError diff --git a/llumnix/queue/ray_queue_client.py b/llumnix/queue/ray_queue_client.py index 524febf3..628c637a 100644 --- a/llumnix/queue/ray_queue_client.py +++ b/llumnix/queue/ray_queue_client.py @@ -24,4 +24,4 @@ async def put_nowait(self, item: Any, server_info: ServerInfo): async def put_nowait_batch(self, items: Iterable, server_info: ServerInfo): output_queue = server_info.request_output_queue - return await output_queue.actor.put_nowait_batch.remote(items) \ No newline at end of file + return await output_queue.actor.put_nowait_batch.remote(items) diff --git a/llumnix/queue/zmq_client.py b/llumnix/queue/zmq_client.py index 0aac321b..afbdf170 100644 --- a/llumnix/queue/zmq_client.py +++ b/llumnix/queue/zmq_client.py @@ -23,7 +23,7 @@ from llumnix.server_info import ServerInfo from llumnix.queue.zmq_utils import (RPC_GET_DATA_TIMEOUT_MS, RPC_SOCKET_LIMIT_CUTOFF, RPC_ZMQ_HWM, RPC_SUCCESS_STR, - RPCClientClosedError, RPC_REQUEST_TYPE, RPCUtilityRequest, RPCPutNoWaitQueueRequest, + RPCClientClosedError, RPC_REQUEST_TYPE, RPCUtilityRequest, RPCPutNoWaitQueueRequest, RPCPutNoWaitBatchQueueRequest, get_open_zmq_ipc_path) logger = init_logger(__name__)