|
25 | 25 |
|
26 | 26 | @override_settings( |
27 | 27 | TASKS={ |
28 | | - "default": {"BACKEND": "django_tasks.backends.dummy.DummyBackend"}, |
| 28 | + "default": { |
| 29 | + "BACKEND": "django_tasks.backends.dummy.DummyBackend", |
| 30 | + "QUEUES": ["default", "queue_1"], |
| 31 | + }, |
29 | 32 | "immediate": {"BACKEND": "django_tasks.backends.immediate.ImmediateBackend"}, |
30 | 33 | "missing": {"BACKEND": "does.not.exist"}, |
31 | 34 | } |
@@ -122,27 +125,17 @@ async def test_refresh_result(self) -> None: |
122 | 125 |
|
123 | 126 | self.assertEqual(dataclasses.asdict(result), original_result) |
124 | 127 |
|
125 | | - async def test_naive_datetime(self) -> None: |
| 128 | + def test_naive_datetime(self) -> None: |
126 | 129 | with self.assertRaisesMessage( |
127 | 130 | InvalidTaskError, "run_after must be an aware datetime" |
128 | 131 | ): |
129 | | - test_tasks.noop_task.using(run_after=datetime.now()).enqueue() |
130 | | - |
131 | | - with self.assertRaisesMessage( |
132 | | - InvalidTaskError, "run_after must be an aware datetime" |
133 | | - ): |
134 | | - await test_tasks.noop_task.using(run_after=datetime.now()).aenqueue() |
135 | | - |
136 | | - async def test_invalid_priority(self) -> None: |
137 | | - with self.assertRaisesMessage( |
138 | | - InvalidTaskError, "priority must be zero or greater" |
139 | | - ): |
140 | | - test_tasks.noop_task.using(priority=-1).enqueue() |
| 132 | + test_tasks.noop_task.using(run_after=datetime.now()) |
141 | 133 |
|
| 134 | + def test_invalid_priority(self) -> None: |
142 | 135 | with self.assertRaisesMessage( |
143 | 136 | InvalidTaskError, "priority must be zero or greater" |
144 | 137 | ): |
145 | | - await test_tasks.noop_task.using(priority=-1).aenqueue() |
| 138 | + test_tasks.noop_task.using(priority=-1) |
146 | 139 |
|
147 | 140 | def test_call_task(self) -> None: |
148 | 141 | self.assertEqual(test_tasks.calculate_meaning_of_life.call(), 42) |
|
0 commit comments