detect_quorum_queues
Detect if any of the queues are quorum queues.
def detect_quorum_queues(
app: Celery,
driver_type: str
) - > tuple[bool, str]
Detect if any of the queues are quorum queues.
Parameters
| Name | Type | Description |
|---|---|---|
| app | Celery | The Celery application instance containing the AMQP configuration and queue definitions |
| driver_type | str | The broker transport type string used to determine if the backend is RabbitMQ (e.g., 'amqp') |
Returns
| Type | Description |
|---|---|
tuple[bool, str] | A tuple containing a boolean indicating if any of the queues are quorum queues and the name of the first quorum queue found or an empty string if no quorum queues were found. |