diff --git a/django/tasks/backends/base.py b/django/tasks/backends/base.py index d35e16d80f..51f42a0fbb 100644 --- a/django/tasks/backends/base.py +++ b/django/tasks/backends/base.py @@ -9,7 +9,6 @@ from django.tasks import DEFAULT_QUEUE_NAME from django.tasks.exceptions import InvalidTaskError from django.tasks.task import MAX_PRIORITY, MIN_PRIORITY, Task from django.tasks.utils import is_global_function -from django.test.testcases import _DatabaseFailure from django.utils import timezone @@ -40,11 +39,6 @@ class BaseTaskBackend(metaclass=ABCMeta): if not connections.settings: return False - # If connections are disabled during tests, there's nothing to commit to - for conn in connections.all(): - if isinstance(conn.connect, _DatabaseFailure): - return False - if isinstance(task.enqueue_on_commit, bool): return task.enqueue_on_commit diff --git a/tests/tasks/test_dummy_backend.py b/tests/tasks/test_dummy_backend.py index 5470dac945..5258d9e4f2 100644 --- a/tests/tasks/test_dummy_backend.py +++ b/tests/tasks/test_dummy_backend.py @@ -99,7 +99,7 @@ class DummyBackendTestCase(SimpleTestCase): await default_task_backend.aget_result("123") def test_enqueue_on_commit(self): - self.assertFalse( + self.assertTrue( default_task_backend._get_enqueue_on_commit_for_task( test_tasks.enqueue_on_commit_task ) @@ -115,6 +115,8 @@ class DummyBackendTestCase(SimpleTestCase): class DummyBackendTransactionTestCase(TransactionTestCase): + available_apps = [] + @override_settings( TASKS={ "default": { diff --git a/tests/tasks/test_immediate_backend.py b/tests/tasks/test_immediate_backend.py index ad12908538..6ed0a083be 100644 --- a/tests/tasks/test_immediate_backend.py +++ b/tests/tasks/test_immediate_backend.py @@ -171,7 +171,7 @@ class ImmediateBackendTestCase(SimpleTestCase): ) def test_enqueue_on_commit(self): - self.assertFalse( + self.assertTrue( default_task_backend._get_enqueue_on_commit_for_task( test_tasks.enqueue_on_commit_task ) @@ -186,6 +186,8 @@ class ImmediateBackendTestCase(SimpleTestCase): class ImmediateBackendTransactionTestCase(TransactionTestCase): + available_apps = [] + @override_settings( TASKS={ "default": {