refactor: tenant queues settings

This commit is contained in:
Jonathan Kössler 2024-08-19 14:37:48 +02:00
parent 5020e54dcc
commit dba348a621
3 changed files with 3 additions and 3 deletions

View File

@ -34,7 +34,7 @@ the [complete example](pyinfra/examples.py).
| Environment Variable | Internal / .toml Name | Description | | Environment Variable | Internal / .toml Name | Description |
| ------------------------------------------ | --------------------------------------- | ----------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------- | | ------------------------------------------ | --------------------------------------- | ----------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------- |
| LOGGING\_\_LEVEL | logging.level | Log level | | LOGGING\_\_LEVEL | logging.level | Log level |
| CONCURRENCY\_\_ENABLED | concurrency.enabled | Enable multi tenant queue mode | | DYNAMIC_TENANT_QUEUES\_\_ENABLED | dynamic_tenant_queues.enabled | Enable queues per tenant that are dynamically created mode |
| METRICS\_\_PROMETHEUS\_\_ENABLED | metrics.prometheus.enabled | Enable Prometheus metrics collection | | METRICS\_\_PROMETHEUS\_\_ENABLED | metrics.prometheus.enabled | Enable Prometheus metrics collection |
| METRICS\_\_PROMETHEUS\_\_PREFIX | metrics.prometheus.prefix | Prefix for Prometheus metrics (e.g. {product}-{service}) | | METRICS\_\_PROMETHEUS\_\_PREFIX | metrics.prometheus.prefix | Prefix for Prometheus metrics (e.g. {product}-{service}) |
| WEBSERVER\_\_HOST | webserver.host | Host of the webserver (offering e.g. /prometheus, /ready and /health endpoints) | | WEBSERVER\_\_HOST | webserver.host | Host of the webserver (offering e.g. /prometheus, /ready and /health endpoints) |

View File

@ -48,7 +48,7 @@ def start_standard_queue_consumer(
instrument_pika() instrument_pika()
instrument_app(app) instrument_app(app)
if settings.concurrency.enabled: if settings.dynamic_tenant_queues.enabled:
config = RabbitMQConfig( config = RabbitMQConfig(
host=settings.rabbitmq.host, host=settings.rabbitmq.host,
port=settings.rabbitmq.port, port=settings.rabbitmq.port,

View File

@ -1,6 +1,6 @@
[tool.poetry] [tool.poetry]
name = "pyinfra" name = "pyinfra"
version = "3.2.1" version = "3.2.2"
description = "" description = ""
authors = ["Team Research <research@knecon.com>"] authors = ["Team Research <research@knecon.com>"]
license = "All rights reseverd" license = "All rights reseverd"