Fixes

apache · Jul 26, 2022 · e90505e · e90505e
1 parent 1d1039d
commit e90505e
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/tests/providers/google/cloud/operators/test_dataproc.py b/tests/providers/google/cloud/operators/test_dataproc.py
@@ -63,7 +63,7 @@
 AIRFLOW_VERSION = "v" + airflow_version.replace(".", "-").replace("+", "-")
 
 DATAPROC_PATH = "airflow.providers.google.cloud.operators.dataproc.{}"
-COMPOSER_TRIGGERS_STRING = "airflow.providers.google.cloud.triggers.dataproc.{}"
+DATAPROC_TRIGGERS_STRING = "airflow.providers.google.cloud.triggers.dataproc.{}"
 
 TASK_ID = "task-id"
 GCP_PROJECT = "test-project"
@@ -907,7 +907,7 @@ def test_execute_async(self, mock_hook):
         )
 
     @mock.patch(DATAPROC_PATH.format("DataprocHook"))
-    @mock.patch(COMPOSER_TRIGGERS_STRING.format("DataprocHook"))
+    @mock.patch(DATAPROC_TRIGGERS_STRING.format("DataprocHook"))
     def test_execute_deferrable(self, mock_trigger_hook, mock_hook):
         job = {}
         mock_hook.return_value.submit_job.return_value.reference.job_id = TEST_JOB_ID