Skip to content

Commit

Permalink
lint fixed
Browse files Browse the repository at this point in the history
  • Loading branch information
roma-frolov committed Sep 20, 2024
1 parent 134ffd5 commit 8e1b9a2
Showing 1 changed file with 9 additions and 3 deletions.
12 changes: 9 additions & 3 deletions faststream/prometheus/middleware.py
Original file line number Diff line number Diff line change
Expand Up @@ -43,7 +43,9 @@ def __init__(self, registry: "CollectorRegistry"):
documentation="Received messages size (in bytes)",
labelnames=["broker", "handler"],
registry=registry,
buckets=[pow(2, x) for x in range(31)], # from 2^0 (1 byte) to 2^30 (1024 mb)
buckets=[
pow(2, x) for x in range(31)
], # from 2^0 (1 byte) to 2^30 (1024 mb)
)
self.received_messages_processing_time = Histogram(
name="received_messages_processing_time",
Expand Down Expand Up @@ -94,7 +96,9 @@ def __init__(
self,
msg: Optional[Any] = None,
*,
settings_provider_factory: Callable[[Any], Optional[MetricsSettingsProvider[Any]]],
settings_provider_factory: Callable[
[Any], Optional[MetricsSettingsProvider[Any]]
],
metrics_container: _MetricsContainer,
) -> None:
self._metrics = metrics_container
Expand Down Expand Up @@ -236,7 +240,9 @@ class BasePrometheusMiddleware:
def __init__(
self,
*,
settings_provider_factory: Callable[[Any], Optional[MetricsSettingsProvider[Any]]],
settings_provider_factory: Callable[
[Any], Optional[MetricsSettingsProvider[Any]]
],
registry: "CollectorRegistry",
):
self._metrics = _MetricsContainer(registry)
Expand Down

0 comments on commit 8e1b9a2

Please sign in to comment.