Test backend options are stored correctly

Author: RealOrangeOne

tests/tests/test_custom_backend.py

@@ -1,3 +1,4 @@
+import logging
 from typing import Any
 from unittest import mock
 
@@ -11,16 +12,22 @@
 
 
 class CustomBackend(BaseTaskBackend):
+    def __init__(self, alias: str, params: dict) -> None:
+        super().__init__(alias, params)
+        self.prefix = self.options.get("prefix", "")
+
     def enqueue(self, *args: Any, **kwargs: Any) -> Any:
-        pass
+        logger = logging.getLogger(__name__)
+        logger.info(f"{self.prefix}Task enqueued.")
 
 
 @override_settings(
     TASKS={
         "default": {
             "BACKEND": get_module_path(CustomBackend),
             "ENQUEUE_ON_COMMIT": False,
-        }
+            "OPTIONS": {"prefix": "PREFIX: "},
+        },
     }
 )
 class CustomBackendTestCase(SimpleTestCase):
@@ -41,3 +48,9 @@ def test_backend_does_not_support_priority(self) -> None:
         ):
             test_tasks.noop_task.using(priority=10)
 
+    def test_options(self) -> None:
+        with self.assertLogs(__name__, level="INFO") as captured_logs:
+            test_tasks.noop_task.enqueue()
+        self.assertEqual(len(captured_logs.output), 1)
+        self.assertIn("PREFIX: Task enqueued", captured_logs.output[0])
+

tests/tests/test_database_backend.py

@@ -77,6 +77,8 @@ def get_task_count_in_new_connection(self) -> int:
     def test_using_correct_backend(self) -> None:
         self.assertEqual(default_task_backend, tasks["default"])
         self.assertIsInstance(tasks["default"], DatabaseBackend)
+        self.assertEqual(default_task_backend.alias, "default")
+        self.assertEqual(default_task_backend.options, {})
 
     def test_enqueue_task(self) -> None:
         for task in [test_tasks.noop_task, test_tasks.noop_task_async]:

tests/tests/test_dummy_backend.py

@@ -35,6 +35,8 @@ def setUp(self) -> None:
     def test_using_correct_backend(self) -> None:
         self.assertEqual(default_task_backend, tasks["default"])
         self.assertIsInstance(tasks["default"], DummyBackend)
+        self.assertEqual(default_task_backend.alias, "default")
+        self.assertEqual(default_task_backend.options, {})
 
     def test_enqueue_task(self) -> None:
         for task in [test_tasks.noop_task, test_tasks.noop_task_async]:

tests/tests/test_immediate_backend.py

@@ -26,6 +26,8 @@ class ImmediateBackendTestCase(SimpleTestCase):
     def test_using_correct_backend(self) -> None:
         self.assertEqual(default_task_backend, tasks["default"])
         self.assertIsInstance(tasks["default"], ImmediateBackend)
+        self.assertEqual(default_task_backend.alias, "default")
+        self.assertEqual(default_task_backend.options, {})
 
     def test_enqueue_task(self) -> None:
         for task in [test_tasks.noop_task, test_tasks.noop_task_async]:

tests/tests/test_rq_backend.py

@@ -92,6 +92,8 @@ def run_worker(self) -> None:
     def test_using_correct_backend(self) -> None:
         self.assertEqual(default_task_backend, tasks["default"])
         self.assertIsInstance(tasks["default"], RQBackend)
+        self.assertEqual(default_task_backend.alias, "default")
+        self.assertEqual(default_task_backend.options, {})
 
     def test_enqueue_task(self) -> None:
         for task in [test_tasks.noop_task, test_tasks.noop_task_async]: