@@ -379,7 +379,9 @@ def _dummy_recurring_task_3() -> None:
379379
380380 # Then - we should have exactly one RecurringTaskRun for each task
381381 for i in range (1 , 4 ):
382- task_identifier = f"test_unit_task_processor_processor._dummy_recurring_task_{ i } "
382+ task_identifier = (
383+ f"test_unit_task_processor_processor._dummy_recurring_task_{ i } "
384+ )
383385 assert (
384386 RecurringTaskRun .objects .using (database )
385387 .filter (task__task_identifier = task_identifier )
@@ -522,7 +524,9 @@ def test_run_task_runs_task_and_creates_task_run_object_when_failure(
522524 task_runs = run_tasks (database )
523525
524526 # Then
525- assert len (task_runs ) == TaskRun .objects .using (database ).filter (task = task ).count () == 1
527+ assert (
528+ len (task_runs ) == TaskRun .objects .using (database ).filter (task = task ).count () == 1
529+ )
526530 task_run = task_runs [0 ]
527531 assert task_run .result == TaskResult .FAILURE .value
528532 assert task_run .started_at
@@ -577,7 +581,9 @@ def test_run_task_runs_failed_task_again(
577581
578582 # Then
579583 task_runs = first_task_runs + second_task_runs
580- assert len (task_runs ) == TaskRun .objects .using (database ).filter (task = task ).count () == 2
584+ assert (
585+ len (task_runs ) == TaskRun .objects .using (database ).filter (task = task ).count () == 2
586+ )
581587
582588 # Then
583589 for task_run in task_runs :
@@ -733,9 +739,13 @@ def _fake_recurring_task() -> None:
733739
734740 dummy_task_identifier = dummy_task .task_identifier
735741 raise_exception_task_identifier = raise_exception_task .task_identifier
736- recurring_task_identifier = RecurringTask .objects .using (database ).latest (
737- "created_at" ,
738- ).task_identifier
742+ recurring_task_identifier = (
743+ RecurringTask .objects .using (database )
744+ .latest (
745+ "created_at" ,
746+ )
747+ .task_identifier
748+ )
739749
740750 Task .create (
741751 dummy_task_identifier ,
0 commit comments