From 3c3580d3bc6c842380709a1c1619ec237e82c8ec Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Jonathan=20K=C3=B6ssler?= Date: Fri, 12 Jul 2024 12:26:56 +0200 Subject: [PATCH] feat: add backwards compatibility --- pyinfra/examples.py | 8 +------- 1 file changed, 1 insertion(+), 7 deletions(-) diff --git a/pyinfra/examples.py b/pyinfra/examples.py index 199a9cf..9c21d9e 100644 --- a/pyinfra/examples.py +++ b/pyinfra/examples.py @@ -4,12 +4,9 @@ from dynaconf import Dynaconf from fastapi import FastAPI from kn_utils.logging import logger -# from threading import Thread from pyinfra.config.loader import get_pyinfra_validators, validate_settings from pyinfra.queue.async_tenants_v2 import RabbitMQConfig, RabbitMQHandler from pyinfra.queue.callback import Callback - -# from pyinfra.queue.threaded_tenants import ServiceQueueManager, TenantQueueManager from pyinfra.queue.manager import QueueManager from pyinfra.utils.opentelemetry import instrument_app, instrument_pika, setup_trace from pyinfra.webserver.prometheus import ( @@ -56,9 +53,6 @@ def start_standard_queue_consumer( app = app or FastAPI() - # tenant_manager = TenantQueueManager(settings) - # service_manager = ServiceQueueManager(settings) - if settings.metrics.prometheus.enabled: logger.info("Prometheus metrics enabled.") app = add_prometheus_endpoint(app) @@ -70,7 +64,7 @@ def start_standard_queue_consumer( instrument_pika() instrument_app(app) - if settings.multiple_tenants.enabled: + if settings.concurrency.enabled: config = get_rabbitmq_config(settings) manager = RabbitMQHandler( config=config, tenant_service_url=settings.storage.tenant_server.endpoint, message_processor=callback