From 0bfc7a15d095fe83ecc82b50561a93c177fece2d Mon Sep 17 00:00:00 2001
From: "Kevin H. Luu" <khluu000@gmail.com>
Date: Wed, 16 Sep 2026 21:13:15 -0700
Subject: [PATCH] [CI] Fix ruff docstring violations in EC connector files
 (#57283)

Signed-off-by: khluu <khluu000@gmail.com>
---
 .../ec_transfer/ec_connector/base.py          |  9 +++------
 .../ec_transfer/ec_connector/metrics.py       | 19 ++++++-------------
 2 files changed, 9 insertions(+), 19 deletions(-)

diff --git a/vllm/distributed/ec_transfer/ec_connector/base.py b/vllm/distributed/ec_transfer/ec_connector/base.py
index 716f443af2..c56d2cc212 100644
--- a/vllm/distributed/ec_transfer/ec_connector/base.py
+++ b/vllm/distributed/ec_transfer/ec_connector/base.py
@@ -226,8 +226,7 @@ class ECConnectorBase(ABC):
         return None
 
     def get_ec_connector_stats(self) -> "ECConnectorStats | None":
-        """
-        Get the EC connector stats collected during the last interval.
+        """Get the EC connector stats collected during the last interval.
 
         Callable on either a worker-side or scheduler-side connector
         instance: the worker-side instance reports stats gathered during
@@ -358,8 +357,7 @@ class ECConnectorBase(ABC):
     def build_ec_connector_stats(
         cls, data: dict[str, Any] | None = None
     ) -> "ECConnectorStats | None":
-        """
-        ECConnectorStats resolution method. This method allows dynamically
+        """ECConnectorStats resolution method. This method allows dynamically
         registered connectors to return their own ECConnectorStats object,
         which can implement custom aggregation logic on the data dict.
         """
@@ -373,8 +371,7 @@ class ECConnectorBase(ABC):
         labelnames: list[str],
         per_engine_labelvalues: dict[int, list[object]],
     ) -> "ECConnectorPromMetrics | None":
-        """
-        Create an ECConnectorPromMetrics subclass which should register
+        """Create an ECConnectorPromMetrics subclass which should register
         per-connector Prometheus metrics and implement observe() to
         expose connector transfer stats via Prometheus.
         """
diff --git a/vllm/distributed/ec_transfer/ec_connector/metrics.py b/vllm/distributed/ec_transfer/ec_connector/metrics.py
index 4a329096ce..0eb20b9863 100644
--- a/vllm/distributed/ec_transfer/ec_connector/metrics.py
+++ b/vllm/distributed/ec_transfer/ec_connector/metrics.py
@@ -17,8 +17,7 @@ logger = init_logger(__name__)
 
 @dataclass
 class ECConnectorStats:
-    """
-    Base class for EC Connector Stats, a container for transfer performance
+    """Base class for EC Connector Stats, a container for transfer performance
     metrics or otherwise important telemetry from the connector.
     All sub-classes need to be serializable as stats are sent from worker to
     logger process.
@@ -31,14 +30,11 @@ class ECConnectorStats:
         raise NotImplementedError
 
     def aggregate(self, other: "ECConnectorStats") -> "ECConnectorStats":
-        """
-        Aggregate stats with another `ECConnectorStats` object.
-        """
+        """Aggregate stats with another `ECConnectorStats` object."""
         raise NotImplementedError
 
     def reduce(self) -> dict[str, int | float]:
-        """
-        Reduce the observations collected during a time interval to one or
+        """Reduce the observations collected during a time interval to one or
         more representative values (eg avg/median/sum of the series).
         This is meant to be called by the logger to produce a summary of the
         stats for the last time interval.
@@ -107,8 +103,7 @@ class ECConnectorLogging:
 
 
 class ECConnectorPromMetrics:
-    """
-    A base class for per-connector Prometheus metric registration
+    """A base class for per-connector Prometheus metric registration
     and recording.
     """
 
@@ -127,8 +122,7 @@ class ECConnectorPromMetrics:
         self.per_engine_labelvalues = per_engine_labelvalues
 
     def observe(self, transfer_stats_data: dict[str, Any], engine_idx: int = 0):
-        """
-        Record the supplied transfer statistics to Prometheus metrics. These
+        """Record the supplied transfer statistics to Prometheus metrics. These
         statistics are engine-specific, and should be recorded to a metric
         with the appropriate 'engine' label. These metric instances can be
         created using the create_metric_per_engine() helper method.
@@ -137,8 +131,7 @@ class ECConnectorPromMetrics:
 
 
 class ECConnectorProm:
-    """
-    Support for registering per-connector Prometheus metrics, and
+    """Support for registering per-connector Prometheus metrics, and
     recording transfer statistics to those metrics. Uses
     ECConnectorBase.build_prom_metrics().
     """