mirrors/django
1
0
Fork 0
mirror of https://github.com/django/django.git synced 2025-07-04 01:39:20 +00:00
Code Issues 32 Releases Wiki Activity

Remove stray type ignore comments

Browse Source
This commit is contained in:
Jake Howard 2024-09-27 11:41:12 +01:00
parent 310412c2f1
commit 23a316529d
No known key found for this signature in database
GPG Key ID: 57AFB45680EDD477
3 changed files with 27 additions and 67 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

46
tests/tasks/test_dummy_backend.py
View File

@ -15,7 +15,7 @@ from . import tasks as test_tasks
) )
class DummyBackendTestCase(SimpleTestCase): class DummyBackendTestCase(SimpleTestCase):
def setUp(self): def setUp(self):
default_task_backend.clear() # type:ignore[attr-defined] default_task_backend.clear()
def test_using_correct_backend(self): def test_using_correct_backend(self):
self.assertEqual(default_task_backend, tasks["default"]) self.assertEqual(default_task_backend, tasks["default"])
@ -35,9 +35,7 @@ class DummyBackendTestCase(SimpleTestCase):
self.assertEqual(result.args, [1]) self.assertEqual(result.args, [1])
self.assertEqual(result.kwargs, {"two": 3}) self.assertEqual(result.kwargs, {"two": 3})
self.assertIn( self.assertIn(result, default_task_backend.results)
result, default_task_backend.results
) # type:ignore[attr-defined]
async def test_enqueue_task_async(self): async def test_enqueue_task_async(self):
for task in [test_tasks.noop_task, test_tasks.noop_task_async]: for task in [test_tasks.noop_task, test_tasks.noop_task_async]:
@ -53,9 +51,7 @@ class DummyBackendTestCase(SimpleTestCase):
self.assertEqual(result.args, []) self.assertEqual(result.args, [])
self.assertEqual(result.kwargs, {}) self.assertEqual(result.kwargs, {})
self.assertIn( self.assertIn(result, default_task_backend.results)
result, default_task_backend.results
) # type:ignore[attr-defined]
def test_get_result(self): def test_get_result(self):
result = default_task_backend.enqueue(test_tasks.noop_task, (), {}) result = default_task_backend.enqueue(test_tasks.noop_task, (), {})
@ -76,7 +72,7 @@ class DummyBackendTestCase(SimpleTestCase):
test_tasks.calculate_meaning_of_life, (), {} test_tasks.calculate_meaning_of_life, (), {}
) )
enqueued_result = default_task_backend.results[0] # type:ignore[attr-defined] enqueued_result = default_task_backend.results[0]
object.__setattr__(enqueued_result, "status", ResultStatus.COMPLETE) object.__setattr__(enqueued_result, "status", ResultStatus.COMPLETE)
self.assertEqual(result.status, ResultStatus.NEW) self.assertEqual(result.status, ResultStatus.NEW)
@ -88,7 +84,7 @@ class DummyBackendTestCase(SimpleTestCase):
test_tasks.calculate_meaning_of_life, (), {} test_tasks.calculate_meaning_of_life, (), {}
) )
enqueued_result = default_task_backend.results[0] # type:ignore[attr-defined] enqueued_result = default_task_backend.results[0]
object.__setattr__(enqueued_result, "status", ResultStatus.COMPLETE) object.__setattr__(enqueued_result, "status", ResultStatus.COMPLETE)
self.assertEqual(result.status, ResultStatus.NEW) self.assertEqual(result.status, ResultStatus.NEW)
@ -136,13 +132,9 @@ class DummyBackendTransactionTestCase(TransactionTestCase):
with transaction.atomic(): with transaction.atomic():
test_tasks.noop_task.enqueue() test_tasks.noop_task.enqueue()
self.assertEqual( self.assertEqual(len(default_task_backend.results), 0)
len(default_task_backend.results), 0
) # type:ignore[attr-defined]
self.assertEqual( self.assertEqual(len(default_task_backend.results), 1)
len(default_task_backend.results), 1
) # type:ignore[attr-defined]
@override_settings( @override_settings(
TASKS={ TASKS={
@ -163,13 +155,9 @@ class DummyBackendTransactionTestCase(TransactionTestCase):
self.assertIsNotNone(result.enqueued_at) self.assertIsNotNone(result.enqueued_at)
self.assertEqual( self.assertEqual(len(default_task_backend.results), 1)
len(default_task_backend.results), 1
) # type:ignore[attr-defined]
self.assertEqual( self.assertEqual(len(default_task_backend.results), 1)
len(default_task_backend.results), 1
) # type:ignore[attr-defined]
@override_settings( @override_settings(
TASKS={ TASKS={
@ -189,13 +177,9 @@ class DummyBackendTransactionTestCase(TransactionTestCase):
self.assertIsNone(result.enqueued_at) self.assertIsNone(result.enqueued_at)
self.assertEqual( self.assertEqual(len(default_task_backend.results), 0)
len(default_task_backend.results), 0
) # type:ignore[attr-defined]
self.assertEqual( self.assertEqual(len(default_task_backend.results), 1)
len(default_task_backend.results), 1
) # type:ignore[attr-defined]
self.assertIsNone(result.enqueued_at) self.assertIsNone(result.enqueued_at)
result.refresh() result.refresh()
self.assertIsNotNone(result.enqueued_at) self.assertIsNotNone(result.enqueued_at)
@ -222,13 +206,9 @@ class DummyBackendTransactionTestCase(TransactionTestCase):
self.assertIsNone(result.enqueued_at) self.assertIsNone(result.enqueued_at)
self.assertEqual( self.assertEqual(len(default_task_backend.results), 0)
len(default_task_backend.results), 0
) # type:ignore[attr-defined]
self.assertEqual( self.assertEqual(len(default_task_backend.results), 1)
len(default_task_backend.results), 1
) # type:ignore[attr-defined]
self.assertIsNone(result.enqueued_at) self.assertIsNone(result.enqueued_at)
result.refresh() result.refresh()
self.assertIsNotNone(result.enqueued_at) self.assertIsNotNone(result.enqueued_at)

34
tests/tasks/test_immediate_backend.py
View File

@ -27,12 +27,8 @@ class ImmediateBackendTestCase(SimpleTestCase):
self.assertEqual(result.status, ResultStatus.COMPLETE) self.assertEqual(result.status, ResultStatus.COMPLETE)
self.assertIsNotNone(result.started_at) self.assertIsNotNone(result.started_at)
self.assertIsNotNone(result.finished_at) self.assertIsNotNone(result.finished_at)
self.assertGreaterEqual( self.assertGreaterEqual(result.started_at, result.enqueued_at)
result.started_at, result.enqueued_at self.assertGreaterEqual(result.finished_at, result.started_at)
) # type:ignore[arg-type, misc]
self.assertGreaterEqual(
result.finished_at, result.started_at
) # type:ignore[arg-type, misc]
self.assertIsNone(result.return_value) self.assertIsNone(result.return_value)
self.assertEqual(result.task, task) self.assertEqual(result.task, task)
self.assertEqual(result.args, [1]) self.assertEqual(result.args, [1])
@ -46,12 +42,8 @@ class ImmediateBackendTestCase(SimpleTestCase):
self.assertEqual(result.status, ResultStatus.COMPLETE) self.assertEqual(result.status, ResultStatus.COMPLETE)
self.assertIsNotNone(result.started_at) self.assertIsNotNone(result.started_at)
self.assertIsNotNone(result.finished_at) self.assertIsNotNone(result.finished_at)
self.assertGreaterEqual( self.assertGreaterEqual(result.started_at, result.enqueued_at)
result.started_at, result.enqueued_at self.assertGreaterEqual(result.finished_at, result.started_at)
) # type:ignore[arg-type, misc]
self.assertGreaterEqual(
result.finished_at, result.started_at
) # type:ignore[arg-type, misc]
self.assertIsNone(result.return_value) self.assertIsNone(result.return_value)
self.assertEqual(result.task, task) self.assertEqual(result.task, task)
self.assertEqual(result.args, []) self.assertEqual(result.args, [])
@ -85,12 +77,8 @@ class ImmediateBackendTestCase(SimpleTestCase):
self.assertEqual(result.status, ResultStatus.FAILED) self.assertEqual(result.status, ResultStatus.FAILED)
self.assertIsNotNone(result.started_at) self.assertIsNotNone(result.started_at)
self.assertIsNotNone(result.finished_at) self.assertIsNotNone(result.finished_at)
self.assertGreaterEqual( self.assertGreaterEqual(result.started_at, result.enqueued_at)
result.started_at, result.enqueued_at self.assertGreaterEqual(result.finished_at, result.started_at)
) # type:ignore[arg-type, misc]
self.assertGreaterEqual(
result.finished_at, result.started_at
) # type:ignore[arg-type, misc]
self.assertIsInstance(result.exception, exception) self.assertIsInstance(result.exception, exception)
self.assertTrue( self.assertTrue(
result.traceback result.traceback
@ -117,12 +105,8 @@ class ImmediateBackendTestCase(SimpleTestCase):
self.assertEqual(result.status, ResultStatus.FAILED) self.assertEqual(result.status, ResultStatus.FAILED)
self.assertIsNotNone(result.started_at) self.assertIsNotNone(result.started_at)
self.assertIsNotNone(result.finished_at) self.assertIsNotNone(result.finished_at)
self.assertGreaterEqual( self.assertGreaterEqual(result.started_at, result.enqueued_at)
result.started_at, result.enqueued_at self.assertGreaterEqual(result.finished_at, result.started_at)
) # type:ignore[arg-type,misc]
self.assertGreaterEqual(
result.finished_at, result.started_at
) # type:ignore[arg-type,misc]
self.assertIsNone(result._return_value) self.assertIsNone(result._return_value)
self.assertIsNone(result.traceback) self.assertIsNone(result.traceback)
@ -158,7 +142,7 @@ class ImmediateBackendTestCase(SimpleTestCase):
NotImplementedError, NotImplementedError,
"This backend does not support retrieving or refreshing results.", "This backend does not support retrieving or refreshing results.",
): ):
await default_task_backend.aget_result(123) # type:ignore[arg-type] await default_task_backend.aget_result(123)
async def test_cannot_refresh_result(self): async def test_cannot_refresh_result(self):
result = await default_task_backend.aenqueue( result = await default_task_backend.aenqueue(

14
tests/tasks/test_tasks.py
View File

@ -36,7 +36,7 @@ from . import tasks as test_tasks
) )
class TaskTestCase(SimpleTestCase): class TaskTestCase(SimpleTestCase):
def setUp(self): def setUp(self):
default_task_backend.clear() # type:ignore[attr-defined] default_task_backend.clear()
def test_using_correct_backend(self): def test_using_correct_backend(self):
self.assertEqual(default_task_backend, tasks["default"]) self.assertEqual(default_task_backend, tasks["default"])
@ -55,9 +55,7 @@ class TaskTestCase(SimpleTestCase):
self.assertEqual(result.args, []) self.assertEqual(result.args, [])
self.assertEqual(result.kwargs, {}) self.assertEqual(result.kwargs, {})
self.assertEqual( self.assertEqual(default_task_backend.results, [result])
default_task_backend.results, [result]
) # type:ignore[attr-defined]
async def test_enqueue_task_async(self): async def test_enqueue_task_async(self):
result = await test_tasks.noop_task.aenqueue() result = await test_tasks.noop_task.aenqueue()
@ -67,9 +65,7 @@ class TaskTestCase(SimpleTestCase):
self.assertEqual(result.args, []) self.assertEqual(result.args, [])
self.assertEqual(result.kwargs, {}) self.assertEqual(result.kwargs, {})
self.assertEqual( self.assertEqual(default_task_backend.results, [result])
default_task_backend.results, [result]
) # type:ignore[attr-defined]
def test_using_priority(self): def test_using_priority(self):
self.assertEqual(test_tasks.noop_task.priority, 0) self.assertEqual(test_tasks.noop_task.priority, 0)
@ -168,7 +164,7 @@ class TaskTestCase(SimpleTestCase):
f"priority must be a whole number between {MIN_PRIORITY} and " f"priority must be a whole number between {MIN_PRIORITY} and "
f"{MAX_PRIORITY}", f"{MAX_PRIORITY}",
): ):
test_tasks.noop_task.using(priority=3.1) # type:ignore[arg-type] test_tasks.noop_task.using(priority=3.1)
test_tasks.noop_task.using(priority=100) test_tasks.noop_task.using(priority=100)
test_tasks.noop_task.using(priority=-100) test_tasks.noop_task.using(priority=-100)
@ -224,7 +220,7 @@ class TaskTestCase(SimpleTestCase):
InvalidTaskError, InvalidTaskError,
"Task function must be a globally importable function", "Task function must be a globally importable function",
): ):
task()(invalid_function) # type:ignore[arg-type] task()(invalid_function)
def test_get_backend(self): def test_get_backend(self):
self.assertEqual(test_tasks.noop_task.backend, "default") self.assertEqual(test_tasks.noop_task.backend, "default")