ruff

Author: bpblanken

v03_pipeline/lib/tasks/dataproc/run_pipeline_on_dataproc_test.py

@@ -69,7 +69,7 @@ def test_job_already_exists_success(
         mock_client = mock_job_controller_client.return_value
         mock_client.get_job.return_value = SimpleNamespace(
             status=SimpleNamespace(
-                state=google.cloud.dataproc_v1.types.jobs.JobStatus.State.DONE
+                state=google.cloud.dataproc_v1.types.jobs.JobStatus.State.DONE,
             ),
         )
         worker = luigi.worker.Worker()
@@ -139,7 +139,7 @@ def test_job_success(
             ),
             SimpleNamespace(
                 status=SimpleNamespace(
-                    state=google.cloud.dataproc_v1.types.jobs.JobStatus.State.DONE
+                    state=google.cloud.dataproc_v1.types.jobs.JobStatus.State.DONE,
                 ),
             ),
         ]