[pre-commit.ci] auto fixes from pre-commit.com hooks

for more information, see https://pre-commit.ci

Author: pre-commit-ci[bot]

tests/unit/task_processor/test_unit_task_processor_processor.py

@@ -89,7 +89,9 @@ def test_run_task_runs_task_and_creates_task_run_object_when_success(
     assert cache.get(DEFAULT_CACHE_KEY)
 
     assert (
-        len(task_runs) == TaskRun.objects.using(current_database).filter(task=task).count() == 1
+        len(task_runs)
+        == TaskRun.objects.using(current_database).filter(task=task).count()
+        == 1
     )
     task_run = task_runs[0]
     assert task_run.result == TaskResult.SUCCESS.value
@@ -122,7 +124,9 @@ def test_run_task_kills_task_after_timeout(
 
     # Then
     assert (
-        len(task_runs) == TaskRun.objects.using(current_database).filter(task=task).count() == 1
+        len(task_runs)
+        == TaskRun.objects.using(current_database).filter(task=task).count()
+        == 1
     )
     task_run = task_runs[0]
     assert task_run.result == TaskResult.FAILURE.value
@@ -383,7 +387,9 @@ def _dummy_recurring_task() -> None:
 
     assert cache.get(DEFAULT_CACHE_KEY) == 1
 
-    assert RecurringTaskRun.objects.using(current_database).filter(task=task).count() == 1
+    assert (
+        RecurringTaskRun.objects.using(current_database).filter(task=task).count() == 1
+    )
 
 
 @pytest.mark.multi_database
@@ -473,7 +479,9 @@ def test_run_task_runs_task_and_creates_task_run_object_when_failure(
 
     # Then
     assert (
-        len(task_runs) == TaskRun.objects.using(current_database).filter(task=task).count() == 1
+        len(task_runs)
+        == TaskRun.objects.using(current_database).filter(task=task).count()
+        == 1
     )
     task_run = task_runs[0]
     assert task_run.result == TaskResult.FAILURE.value
@@ -526,7 +534,9 @@ def test_run_task_runs_failed_task_again(
     # Then
     task_runs = first_task_runs + second_task_runs
     assert (
-        len(task_runs) == TaskRun.objects.using(current_database).filter(task=task).count() == 2
+        len(task_runs)
+        == TaskRun.objects.using(current_database).filter(task=task).count()
+        == 2
     )
 
     # Then
@@ -663,7 +673,9 @@ def _fake_recurring_task() -> None:
     dummy_task_identifier = dummy_task.task_identifier
     raise_exception_task_identifier = raise_exception_task.task_identifier
     recurring_task_identifier = (
-        RecurringTask.objects.using(current_database).latest("created_at").task_identifier
+        RecurringTask.objects.using(current_database)
+        .latest("created_at")
+        .task_identifier
     )
 
     Task.create(