cloud logging sink:pre-commit check fix

arvindp25 · arvindp25 · commit e8e66897fcef · 2025-06-29T10:58:31.000Z
diff --git a/providers/google/src/airflow/providers/google/cloud/operators/cloud_logging_sink.py b/providers/google/src/airflow/providers/google/cloud/operators/cloud_logging_sink.py
@@ -268,7 +268,7 @@ def execute(self, context: Context) -> dict[str, Any]:
             elif hasattr(self.update_mask, "paths"):
                 paths = self.update_mask.paths
 
-                self.log.info("Updating fields: %s", ", ".join(paths))
+            self.log.info("Updating fields: %s", ", ".join(paths))
 
             response = hook.update_sink(
                 sink_name=self.sink_name,
diff --git a/providers/google/tests/system/google/cloud/cloud_logging_sink/example_cloud_logging_protobuf_obj.py b/providers/google/tests/system/google/cloud/cloud_logging_sink/example_cloud_logging_protobuf_obj.py
@@ -23,8 +23,8 @@
 # [START howto_operator_import_protobuf_obj]
 from google.cloud.logging_v2.types import LogSink
 from google.protobuf.field_mask_pb2 import FieldMask
-# [END howto_operator_import_protobuf_obj]
 
+# [END howto_operator_import_protobuf_obj]
 from airflow import DAG
 from airflow.providers.google.cloud.operators.cloud_logging_sink import (
     CloudLoggingCreateSinkOperator,
@@ -52,7 +52,7 @@
     create_sink = CloudLoggingCreateSinkOperator(
         task_id="create_sink",
         project_id=PROJECT_ID,
-        unique_writer_identity = False,
+        unique_writer_identity=False,
         sink_config=LogSink(
             **{
                 "name": SINK_NAME,
@@ -92,7 +92,7 @@
                 "disabled": False,
             }
         ),
-        unique_writer_identity = True,
+        unique_writer_identity=True,
         update_mask=FieldMask(paths=["description", "filter", "disabled"]),
         gcp_conn_id=CONN_ID,
     )
diff --git a/providers/google/tests/system/google/cloud/cloud_logging_sink/example_cloud_logging_sink.py b/providers/google/tests/system/google/cloud/cloud_logging_sink/example_cloud_logging_sink.py
@@ -82,7 +82,7 @@
             "disabled": False,
         },
         update_mask={"paths": ["description", "filter", "disabled"]},
-        unique_writer_identity = True,
+        unique_writer_identity=True,
         gcp_conn_id=CONN_ID,
     )
     # [END howto_operator_cloud_logging_update_sink_sink_native_obj]
diff --git a/providers/google/tests/unit/google/cloud/hooks/test_cloud_logging.py b/providers/google/tests/unit/google/cloud/hooks/test_cloud_logging.py
@@ -197,7 +197,7 @@ def test_update_sink_invalid_dict_format(self, cloud_logging_hook):
     @mock.patch("airflow.providers.google.cloud.hooks.cloud_logging.ConfigServiceV2Client")
     def test_update_sink_failure(self, mock_config_client, cloud_logging_hook):
         updated_sink = LogSink(name=SINK_NAME, destination="storage.googleapis.com/new-bucket")
-        updated_mask = {"paths":["name","destination"]}
+        updated_mask = {"paths": ["name", "destination"]}
 
         mock_config_client.return_value.update_sink.side_effect = Exception("Permission denied")
 

Original file line number	Diff line number	Diff line change
`@@ -82,7 +82,7 @@`
`82`	`82`	`"disabled": False,`
`83`	`83`	`},`
`84`	`84`	`update_mask={"paths": ["description", "filter", "disabled"]},`
`85`		`- unique_writer_identity = True,`
	`85`	`+ unique_writer_identity=True,`
`86`	`86`	`gcp_conn_id=CONN_ID,`
`87`	`87`	`)`
`88`	`88`	`# [END howto_operator_cloud_logging_update_sink_sink_native_obj]`