fixed lint

Author: daniel-sanche

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

@@ -19,6 +19,7 @@
     cast,
     Any,
     AsyncIterable,
+    Callable,
     Optional,
     Set,
     Sequence,
@@ -278,6 +279,7 @@ def _build_grpc_channel(self, *args, **kwargs) -> SwappableChannelType:
         Returns:
           a custom wrapped swappable channel
         """
+        create_channel_fn: Callable[[], Any]
         if self._emulator_host is not None:
             # emulators use insecure channel
             create_channel_fn = partial(insecure_channel, self._emulator_host)

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

@@ -17,7 +17,7 @@
 # This file is automatically generated by CrossSync. Do not edit manually.
 
 from __future__ import annotations
-from typing import cast, Any, Optional, Set, Sequence, TYPE_CHECKING
+from typing import cast, Any, Callable, Optional, Set, Sequence, TYPE_CHECKING
 import abc
 import time
 import warnings
@@ -206,6 +206,7 @@ def _build_grpc_channel(self, *args, **kwargs) -> SwappableChannelType:
           - **kwargs: keyword arguments passed by the gapic layer to create a new channel with
         Returns:
           a custom wrapped swappable channel"""
+        create_channel_fn: Callable[[], Any]
         if self._emulator_host is not None:
             create_channel_fn = partial(insecure_channel, self._emulator_host)
         else:

tests/unit/data/_async/test_metrics_interceptor.py

@@ -104,7 +104,6 @@ async def test_unary_unary_interceptor_failure_generic(self):
         instance = self._make_one()
         exc = ValueError("test")
         continuation = CrossSync.Mock(side_effect=exc)
-        call = continuation.return_value
         details = mock.Mock()
         request = mock.Mock()
         with pytest.raises(ValueError) as e:
@@ -119,7 +118,6 @@ async def test_unary_stream_interceptor_success(self):
         instance = self._make_one()
 
         continuation = CrossSync.Mock(return_value=_make_mock_stream_call([1, 2]))
-        call = continuation.return_value
         details = mock.Mock()
         request = mock.Mock()
         wrapper = await instance.intercept_unary_stream(continuation, details, request)
@@ -133,7 +131,6 @@ async def test_unary_stream_interceptor_failure_mid_stream(self):
         instance = self._make_one()
         exc = ValueError("test")
         continuation = CrossSync.Mock(return_value=_make_mock_stream_call([1], exc=exc))
-        call = continuation.return_value
         details = mock.Mock()
         request = mock.Mock()
         wrapper = await instance.intercept_unary_stream(continuation, details, request)

tests/unit/data/_sync_autogen/test_metrics_interceptor.py

@@ -82,7 +82,6 @@ def test_unary_unary_interceptor_failure_generic(self):
         instance = self._make_one()
         exc = ValueError("test")
         continuation = CrossSync._Sync_Impl.Mock(side_effect=exc)
-        call = continuation.return_value
         details = mock.Mock()
         request = mock.Mock()
         with pytest.raises(ValueError) as e:
@@ -96,7 +95,6 @@ def test_unary_stream_interceptor_success(self):
         continuation = CrossSync._Sync_Impl.Mock(
             return_value=_make_mock_stream_call([1, 2])
         )
-        call = continuation.return_value
         details = mock.Mock()
         request = mock.Mock()
         wrapper = instance.intercept_unary_stream(continuation, details, request)
@@ -111,7 +109,6 @@ def test_unary_stream_interceptor_failure_mid_stream(self):
         continuation = CrossSync._Sync_Impl.Mock(
             return_value=_make_mock_stream_call([1], exc=exc)
         )
-        call = continuation.return_value
         details = mock.Mock()
         request = mock.Mock()
         wrapper = instance.intercept_unary_stream(continuation, details, request)