diff --git a/taskiq/middlewares/prometheus_middleware.py b/taskiq/middlewares/prometheus_middleware.py index 56837cf3..01f14867 100644 --- a/taskiq/middlewares/prometheus_middleware.py +++ b/taskiq/middlewares/prometheus_middleware.py @@ -84,22 +84,17 @@ def startup(self) -> None: This function starts prometheus server. It starts it only in case if it's a worker process. """ - from prometheus_client import ( # noqa: PLC0415 - CollectorRegistry, - start_http_server, - ) + from prometheus_client import REGISTRY, start_http_server # noqa: PLC0415 from prometheus_client.multiprocess import ( # noqa: PLC0415 MultiProcessCollector, ) if self.broker.is_worker_process: try: - registry = CollectorRegistry() - MultiProcessCollector(registry) + MultiProcessCollector(REGISTRY) start_http_server( port=self.server_port, addr=self.server_addr, - registry=registry, ) except OSError as exc: logger.debug("Cannot start prometheus server: %s", exc)