authentik.tasks.broker 

 1from django.db.models import QuerySet
 2from django_dramatiq_postgres.broker import PostgresBroker
 3from structlog.stdlib import get_logger
 4
 5LOGGER = get_logger()
 6
 7
 8class Broker(PostgresBroker):
 9    @property
10    def query_set(self) -> QuerySet:
11        return super().query_set.select_related("tenant").filter(tenant__ready=True)
LOGGER = <BoundLoggerLazyProxy(logger=None, wrapper_class=None, processors=None, context_class=None, initial_values={}, logger_factory_args=())>
class Broker(django_dramatiq_postgres.broker.PostgresBroker): 
 9class Broker(PostgresBroker):
10    @property
11    def query_set(self) -> QuerySet:
12        return super().query_set.select_related("tenant").filter(tenant__ready=True)

Base class for broker implementations.

Parameters: middleware(list[Middleware]): The set of middleware that apply to this broker. If you supply this parameter, you are expected to declare all middleware. Most of the time, you'll want to use :meth:.add_middleware instead.

Attributes: actor_options(set[str]): The names of all the options actors may overwrite when they are declared.

query_set: django.db.models.query.QuerySet 
10    @property
11    def query_set(self) -> QuerySet:
12        return super().query_set.select_related("tenant").filter(tenant__ready=True)