diff --git a/airflow/providers/google/cloud/operators/datafusion.py b/airflow/providers/google/cloud/operators/datafusion.py
index f5152d4076..093721d55e 100644
--- a/airflow/providers/google/cloud/operators/datafusion.py
+++ b/airflow/providers/google/cloud/operators/datafusion.py
@@ -81,7 +81,7 @@ def execute(self, context: Dict):
             delegate_to=self.delegate_to,
             api_version=self.api_version,
         )
-        self.log.info("Restarting Data Fusion instace: %s", self.instance_name)
+        self.log.info("Restarting Data Fusion instance: %s", self.instance_name)
         operation = hook.restart_instance(
             instance_name=self.instance_name,
             location=self.location,
@@ -142,7 +142,7 @@ def execute(self, context: Dict):
             delegate_to=self.delegate_to,
             api_version=self.api_version,
         )
-        self.log.info("Deleting Data Fusion instace: %s", self.instance_name)
+        self.log.info("Deleting Data Fusion instance: %s", self.instance_name)
         operation = hook.delete_instance(
             instance_name=self.instance_name,
             location=self.location,
@@ -208,7 +208,7 @@ def execute(self, context: Dict):
             delegate_to=self.delegate_to,
             api_version=self.api_version,
         )
-        self.log.info("Creating Data Fusion instace: %s", self.instance_name)
+        self.log.info("Creating Data Fusion instance: %s", self.instance_name)
         try:
             operation = hook.create_instance(
                 instance_name=self.instance_name,
@@ -301,7 +301,7 @@ def execute(self, context: Dict):
             delegate_to=self.delegate_to,
             api_version=self.api_version,
         )
-        self.log.info("Updating Data Fusion instace: %s", self.instance_name)
+        self.log.info("Updating Data Fusion instance: %s", self.instance_name)
         operation = hook.patch_instance(
             instance_name=self.instance_name,
             instance=self.instance,