diff --git a/django/tasks/__init__.py b/django/tasks/__init__.py index 121c706951..5799dbcf9a 100644 --- a/django/tasks/__init__.py +++ b/django/tasks/__init__.py @@ -38,7 +38,7 @@ class TasksHandler(BaseConnectionHandler): f"Could not find backend '{backend}': {e}" ) from e - return backend_cls({**params, "ALIAS": alias}) + return backend_cls(alias=alias, params=params) tasks = TasksHandler() diff --git a/django/tasks/backends/base.py b/django/tasks/backends/base.py index f72c05417e..d3bf527bc6 100644 --- a/django/tasks/backends/base.py +++ b/django/tasks/backends/base.py @@ -24,10 +24,10 @@ class BaseTaskBackend(metaclass=ABCMeta): supports_get_result = False """Can results be retrieved after the fact (from **any** thread / process)""" - def __init__(self, options): - self.alias = options["ALIAS"] - self.queues = set(options.get("QUEUES", [DEFAULT_QUEUE_NAME])) - self.enqueue_on_commit = bool(options.get("ENQUEUE_ON_COMMIT", True)) + def __init__(self, alias, params): + self.alias = alias + self.queues = set(params.get("QUEUES", [DEFAULT_QUEUE_NAME])) + self.enqueue_on_commit = bool(params.get("ENQUEUE_ON_COMMIT", True)) def _get_enqueue_on_commit_for_task(self, task): """ diff --git a/django/tasks/backends/dummy.py b/django/tasks/backends/dummy.py index d6f063d239..20d7c3e160 100644 --- a/django/tasks/backends/dummy.py +++ b/django/tasks/backends/dummy.py @@ -16,8 +16,8 @@ class DummyBackend(BaseTaskBackend): supports_defer = True supports_async_task = True - def __init__(self, options) -> None: - super().__init__(options) + def __init__(self, alias, params) -> None: + super().__init__(alias, params) self.results = []