Fix styling issues

Author: markurtz

pyproject.toml

@@ -45,6 +45,7 @@ keywords = [
 ]
 dependencies = [
     "click>=8.0.0,<8.2.0",
+    "culsans~=0.9.0",
     "datasets",
     "ftfy>=6.0.0",
     "httpx[http2]<1.0.0",
@@ -150,15 +151,16 @@ indent-style = "space"
 
 [tool.ruff.lint]
 ignore = [
-    "PLR0913",
-    "TC001",
-    "COM812",
-    "ISC001",
-    "TC002",
+    "COM812",  # ignore trailing comma errors due to older Python versions
+    "PD011", # ignore .values usage since ruff assumes it's a Pandas DataFrame
+    "PLR0913",  # ignore too many arguments in function definitions
     "PLW1514", # allow Path.open without encoding
     "RET505", # allow `else` blocks
     "RET506", # allow `else` blocks
-    "PD011", # ignore .values usage since ruff assumes it's a Pandas DataFrame
+    "S311",  # allow standard pseudo-random generators
+    "TC001",  # ignore imports used only for type checking
+    "TC002",  # ignore imports used only for type checking
+    "TC003", # ignore imports used only for type checking
 ]
 select = [
     # Rules reference: https://docs.astral.sh/ruff/rules/

src/guidellm/utils/encoding.py

@@ -12,7 +12,7 @@
 
 import json
 from collections.abc import Mapping
-from typing import Annotated, Any, ClassVar, Generic, Literal, Optional, TypeVar, Union
+from typing import Annotated, Any, ClassVar, Generic, Literal, Optional, TypeVar
 
 try:
     import msgpack

src/guidellm/utils/messaging.py

@@ -856,10 +856,9 @@ def _background_pipe_recv():
                 try:
                     with pipe_lock:
                         pending = pipe_item
-                        pipe_item = None  # Clear after taking
+                        pipe_item = None
 
                     if pending is not None:
-                        # pending is already encoded, just send it directly
                         send_connection.send(pending)
                 except (EOFError, ConnectionResetError):
                     break

tests/unit/utils/test_messaging.py

@@ -556,7 +556,7 @@ async def test_lifecycle_put_get(
         ],
     )
     @async_timeout(10.0)
-    async def test_lifecycle_put_get(
+    async def test_lifecycle_put_get_iter(
         self, multiprocessing_contexts, valid_instances, test_obj
     ):
         instance, constructor_args = valid_instances
@@ -853,7 +853,7 @@ async def test_lifecycle_put_get(self, valid_instances, test_obj):
         ],
     )
     @async_timeout(10.0)
-    async def test_lifecycle_put_get(self, valid_instances, test_obj):
+    async def test_lifecycle_put_get_iter(self, valid_instances, test_obj):
         instance, constructor_args, _, context = valid_instances
 
         if (