🦉 Updates from OwlBot post-processor

See https://github.com/googleapis/repo-automation-bots/blob/main/packages/owl-bot/README.md
googleapis · Jul 27, 2024 · d7ddba0 · d7ddba0
1 parent 0963b4c
commit d7ddba0
Show file tree

Hide file tree

Showing 2 changed files with 106 additions and 82 deletions.
diff --git a/google/cloud/bigtable_v2/services/bigtable/async_client.py b/google/cloud/bigtable_v2/services/bigtable/async_client.py
@@ -340,11 +340,13 @@ def read_rows(
 
         # Certain fields should be provided within the metadata header;
         # add these here.
-        metadata = tuple(metadata) + (
-            gapic_v1.routing_header.to_grpc_metadata(
-                (("table_name", request.table_name),)
-            ),
-        )
+        metadata = tuple(metadata)
+        if all(m[0] != gapic_v1.routing_header.ROUTING_METADATA_KEY for m in metadata):
+            metadata += (
+                gapic_v1.routing_header.to_grpc_metadata(
+                    (("table_name", request.table_name),)
+                ),
+            )
 
         # Validate the universe domain.
         self._client._validate_universe_domain()
@@ -441,11 +443,13 @@ def sample_row_keys(
 
         # Certain fields should be provided within the metadata header;
         # add these here.
-        metadata = tuple(metadata) + (
-            gapic_v1.routing_header.to_grpc_metadata(
-                (("table_name", request.table_name),)
-            ),
-        )
+        metadata = tuple(metadata)
+        if all(m[0] != gapic_v1.routing_header.ROUTING_METADATA_KEY for m in metadata):
+            metadata += (
+                gapic_v1.routing_header.to_grpc_metadata(
+                    (("table_name", request.table_name),)
+                ),
+            )
 
         # Validate the universe domain.
         self._client._validate_universe_domain()
@@ -563,11 +567,13 @@ async def mutate_row(
 
         # Certain fields should be provided within the metadata header;
         # add these here.
-        metadata = tuple(metadata) + (
-            gapic_v1.routing_header.to_grpc_metadata(
-                (("table_name", request.table_name),)
-            ),
-        )
+        metadata = tuple(metadata)
+        if all(m[0] != gapic_v1.routing_header.ROUTING_METADATA_KEY for m in metadata):
+            metadata += (
+                gapic_v1.routing_header.to_grpc_metadata(
+                    (("table_name", request.table_name),)
+                ),
+            )
 
         # Validate the universe domain.
         self._client._validate_universe_domain()
@@ -679,11 +685,13 @@ def mutate_rows(
 
         # Certain fields should be provided within the metadata header;
         # add these here.
-        metadata = tuple(metadata) + (
-            gapic_v1.routing_header.to_grpc_metadata(
-                (("table_name", request.table_name),)
-            ),
-        )
+        metadata = tuple(metadata)
+        if all(m[0] != gapic_v1.routing_header.ROUTING_METADATA_KEY for m in metadata):
+            metadata += (
+                gapic_v1.routing_header.to_grpc_metadata(
+                    (("table_name", request.table_name),)
+                ),
+            )
 
         # Validate the universe domain.
         self._client._validate_universe_domain()
@@ -838,11 +846,13 @@ async def check_and_mutate_row(
 
         # Certain fields should be provided within the metadata header;
         # add these here.
-        metadata = tuple(metadata) + (
-            gapic_v1.routing_header.to_grpc_metadata(
-                (("table_name", request.table_name),)
-            ),
-        )
+        metadata = tuple(metadata)
+        if all(m[0] != gapic_v1.routing_header.ROUTING_METADATA_KEY for m in metadata):
+            metadata += (
+                gapic_v1.routing_header.to_grpc_metadata(
+                    (("table_name", request.table_name),)
+                ),
+            )
 
         # Validate the universe domain.
         self._client._validate_universe_domain()
@@ -936,9 +946,11 @@ async def ping_and_warm(
 
         # Certain fields should be provided within the metadata header;
         # add these here.
-        metadata = tuple(metadata) + (
-            gapic_v1.routing_header.to_grpc_metadata((("name", request.name),)),
-        )
+        metadata = tuple(metadata)
+        if all(m[0] != gapic_v1.routing_header.ROUTING_METADATA_KEY for m in metadata):
+            metadata += (
+                gapic_v1.routing_header.to_grpc_metadata((("name", request.name),)),
+            )
 
         # Validate the universe domain.
         self._client._validate_universe_domain()
@@ -1062,11 +1074,13 @@ async def read_modify_write_row(
 
         # Certain fields should be provided within the metadata header;
         # add these here.
-        metadata = tuple(metadata) + (
-            gapic_v1.routing_header.to_grpc_metadata(
-                (("table_name", request.table_name),)
-            ),
-        )
+        metadata = tuple(metadata)
+        if all(m[0] != gapic_v1.routing_header.ROUTING_METADATA_KEY for m in metadata):
+            metadata += (
+                gapic_v1.routing_header.to_grpc_metadata(
+                    (("table_name", request.table_name),)
+                ),
+            )
 
         # Validate the universe domain.
         self._client._validate_universe_domain()
@@ -1172,11 +1186,13 @@ def generate_initial_change_stream_partitions(
 
         # Certain fields should be provided within the metadata header;
         # add these here.
-        metadata = tuple(metadata) + (
-            gapic_v1.routing_header.to_grpc_metadata(
-                (("table_name", request.table_name),)
-            ),
-        )
+        metadata = tuple(metadata)
+        if all(m[0] != gapic_v1.routing_header.ROUTING_METADATA_KEY for m in metadata):
+            metadata += (
+                gapic_v1.routing_header.to_grpc_metadata(
+                    (("table_name", request.table_name),)
+                ),
+            )
 
         # Validate the universe domain.
         self._client._validate_universe_domain()
@@ -1274,11 +1290,13 @@ def read_change_stream(
 
         # Certain fields should be provided within the metadata header;
         # add these here.
-        metadata = tuple(metadata) + (
-            gapic_v1.routing_header.to_grpc_metadata(
-                (("table_name", request.table_name),)
-            ),
-        )
+        metadata = tuple(metadata)
+        if all(m[0] != gapic_v1.routing_header.ROUTING_METADATA_KEY for m in metadata):
+            metadata += (
+                gapic_v1.routing_header.to_grpc_metadata(
+                    (("table_name", request.table_name),)
+                ),
+            )
 
         # Validate the universe domain.
         self._client._validate_universe_domain()
@@ -1377,11 +1395,13 @@ def execute_query(
 
         # Certain fields should be provided within the metadata header;
         # add these here.
-        metadata = tuple(metadata) + (
-            gapic_v1.routing_header.to_grpc_metadata(
-                (("instance_name", request.instance_name),)
-            ),
-        )
+        metadata = tuple(metadata)
+        if all(m[0] != gapic_v1.routing_header.ROUTING_METADATA_KEY for m in metadata):
+            metadata += (
+                gapic_v1.routing_header.to_grpc_metadata(
+                    (("instance_name", request.instance_name),)
+                ),
+            )
 
         # Validate the universe domain.
         self._client._validate_universe_domain()

diff --git a/google/cloud/bigtable_v2/services/bigtable/client.py b/google/cloud/bigtable_v2/services/bigtable/client.py
@@ -817,9 +817,9 @@ def read_rows(
             )
 
         if header_params:
-            metadata = tuple(metadata) + (
-                gapic_v1.routing_header.to_grpc_metadata(header_params),
-            )
+            metadata = tuple(metadata)
+        if all(m[0] != gapic_v1.routing_header.ROUTING_METADATA_KEY for m in metadata):
+            metadata += (gapic_v1.routing_header.to_grpc_metadata(header_params),)
 
         # Validate the universe domain.
         self._validate_universe_domain()
@@ -933,9 +933,9 @@ def sample_row_keys(
             )
 
         if header_params:
-            metadata = tuple(metadata) + (
-                gapic_v1.routing_header.to_grpc_metadata(header_params),
-            )
+            metadata = tuple(metadata)
+        if all(m[0] != gapic_v1.routing_header.ROUTING_METADATA_KEY for m in metadata):
+            metadata += (gapic_v1.routing_header.to_grpc_metadata(header_params),)
 
         # Validate the universe domain.
         self._validate_universe_domain()
@@ -1070,9 +1070,9 @@ def mutate_row(
             )
 
         if header_params:
-            metadata = tuple(metadata) + (
-                gapic_v1.routing_header.to_grpc_metadata(header_params),
-            )
+            metadata = tuple(metadata)
+        if all(m[0] != gapic_v1.routing_header.ROUTING_METADATA_KEY for m in metadata):
+            metadata += (gapic_v1.routing_header.to_grpc_metadata(header_params),)
 
         # Validate the universe domain.
         self._validate_universe_domain()
@@ -1201,9 +1201,9 @@ def mutate_rows(
             )
 
         if header_params:
-            metadata = tuple(metadata) + (
-                gapic_v1.routing_header.to_grpc_metadata(header_params),
-            )
+            metadata = tuple(metadata)
+        if all(m[0] != gapic_v1.routing_header.ROUTING_METADATA_KEY for m in metadata):
+            metadata += (gapic_v1.routing_header.to_grpc_metadata(header_params),)
 
         # Validate the universe domain.
         self._validate_universe_domain()
@@ -1375,9 +1375,9 @@ def check_and_mutate_row(
             )
 
         if header_params:
-            metadata = tuple(metadata) + (
-                gapic_v1.routing_header.to_grpc_metadata(header_params),
-            )
+            metadata = tuple(metadata)
+        if all(m[0] != gapic_v1.routing_header.ROUTING_METADATA_KEY for m in metadata):
+            metadata += (gapic_v1.routing_header.to_grpc_metadata(header_params),)
 
         # Validate the universe domain.
         self._validate_universe_domain()
@@ -1477,9 +1477,9 @@ def ping_and_warm(
             header_params["app_profile_id"] = request.app_profile_id
 
         if header_params:
-            metadata = tuple(metadata) + (
-                gapic_v1.routing_header.to_grpc_metadata(header_params),
-            )
+            metadata = tuple(metadata)
+        if all(m[0] != gapic_v1.routing_header.ROUTING_METADATA_KEY for m in metadata):
+            metadata += (gapic_v1.routing_header.to_grpc_metadata(header_params),)
 
         # Validate the universe domain.
         self._validate_universe_domain()
@@ -1620,9 +1620,9 @@ def read_modify_write_row(
             )
 
         if header_params:
-            metadata = tuple(metadata) + (
-                gapic_v1.routing_header.to_grpc_metadata(header_params),
-            )
+            metadata = tuple(metadata)
+        if all(m[0] != gapic_v1.routing_header.ROUTING_METADATA_KEY for m in metadata):
+            metadata += (gapic_v1.routing_header.to_grpc_metadata(header_params),)
 
         # Validate the universe domain.
         self._validate_universe_domain()
@@ -1725,11 +1725,13 @@ def generate_initial_change_stream_partitions(
 
         # Certain fields should be provided within the metadata header;
         # add these here.
-        metadata = tuple(metadata) + (
-            gapic_v1.routing_header.to_grpc_metadata(
-                (("table_name", request.table_name),)
-            ),
-        )
+        metadata = tuple(metadata)
+        if all(m[0] != gapic_v1.routing_header.ROUTING_METADATA_KEY for m in metadata):
+            metadata += (
+                gapic_v1.routing_header.to_grpc_metadata(
+                    (("table_name", request.table_name),)
+                ),
+            )
 
         # Validate the universe domain.
         self._validate_universe_domain()
@@ -1824,11 +1826,13 @@ def read_change_stream(
 
         # Certain fields should be provided within the metadata header;
         # add these here.
-        metadata = tuple(metadata) + (
-            gapic_v1.routing_header.to_grpc_metadata(
-                (("table_name", request.table_name),)
-            ),
-        )
+        metadata = tuple(metadata)
+        if all(m[0] != gapic_v1.routing_header.ROUTING_METADATA_KEY for m in metadata):
+            metadata += (
+                gapic_v1.routing_header.to_grpc_metadata(
+                    (("table_name", request.table_name),)
+                ),
+            )
 
         # Validate the universe domain.
         self._validate_universe_domain()
@@ -1933,9 +1937,9 @@ def execute_query(
             header_params["app_profile_id"] = request.app_profile_id
 
         if header_params:
-            metadata = tuple(metadata) + (
-                gapic_v1.routing_header.to_grpc_metadata(header_params),
-            )
+            metadata = tuple(metadata)
+        if all(m[0] != gapic_v1.routing_header.ROUTING_METADATA_KEY for m in metadata):
+            metadata += (gapic_v1.routing_header.to_grpc_metadata(header_params),)
 
         # Validate the universe domain.
         self._validate_universe_domain()