fix: pass None for retry in gapic calls

google/cloud/bigtable/data/_async/_mutate_rows.py

@@ -79,6 +79,7 @@ def __init__(
             table_name=table.table_name,
             app_profile_id=table.app_profile_id,
             metadata=metadata,
+            retry=None,
         )
         # create predicate for determining which errors are retryable
         self.is_retryable = retries.if_exception_type(

google/cloud/bigtable/data/_async/_read_rows.py

@@ -140,6 +140,7 @@ def _read_rows_attempt(self) -> AsyncGenerator[Row, None]:
             self.request,
             timeout=next(self.attempt_timeout_gen),
             metadata=self._metadata,
+            retry=None,
         )
         chunked_stream = self.chunk_stream(gapic_stream)
         return self.merge_rows(chunked_stream)

google/cloud/bigtable/data/_async/client.py

@@ -857,6 +857,7 @@ async def execute_rpc():
                 app_profile_id=self.app_profile_id,
                 timeout=next(attempt_timeout_gen),
                 metadata=metadata,
+                retry=None,
             )
             return [(s.row_key, s.offset_bytes) async for s in results]
 
@@ -1120,6 +1121,7 @@ async def check_and_mutate_row(
             },
             metadata=metadata,
             timeout=operation_timeout,
+            retry=None,
         )
         return result.predicate_matched
 
@@ -1173,6 +1175,7 @@ async def read_modify_write_row(
             },
             metadata=metadata,
             timeout=operation_timeout,
+            retry=None,
         )
         # construct Row from result
         return Row._from_pb(result.row)

tests/unit/data/_async/test__mutate_rows.py

@@ -93,9 +93,10 @@ def test_ctor(self):
         assert client.mutate_rows.call_count == 1
         # gapic_fn should call with table details
         inner_kwargs = client.mutate_rows.call_args[1]
-        assert len(inner_kwargs) == 3
+        assert len(inner_kwargs) == 4
         assert inner_kwargs["table_name"] == table.table_name
         assert inner_kwargs["app_profile_id"] == table.app_profile_id
+        assert inner_kwargs["retry"] is None
         metadata = inner_kwargs["metadata"]
         assert len(metadata) == 1
         assert metadata[0][0] == "x-goog-request-params"

tests/unit/data/_async/test_client.py

@@ -1905,11 +1905,12 @@ async def test_sample_row_keys_gapic_params(self):
                     await table.sample_row_keys(attempt_timeout=expected_timeout)
                     args, kwargs = sample_row_keys.call_args
                     assert len(args) == 0
-                    assert len(kwargs) == 4
+                    assert len(kwargs) == 5
                     assert kwargs["timeout"] == expected_timeout
                     assert kwargs["app_profile_id"] == expected_profile
                     assert kwargs["table_name"] == table.table_name
                     assert kwargs["metadata"] is not None
+                    assert kwargs["retry"] is None
 
     @pytest.mark.parametrize("include_app_profile", [True, False])
     @pytest.mark.asyncio