fix: remove gRPC send/recv limits; add enums to __init__.py

google/cloud/videointelligence_v1/services/video_intelligence_service/transports/__init__.py

@@ -30,7 +30,6 @@
 _transport_registry["grpc"] = VideoIntelligenceServiceGrpcTransport
 _transport_registry["grpc_asyncio"] = VideoIntelligenceServiceGrpcAsyncIOTransport
 
-
 __all__ = (
     "VideoIntelligenceServiceTransport",
     "VideoIntelligenceServiceGrpcTransport",

google/cloud/videointelligence_v1/services/video_intelligence_service/transports/grpc.py

@@ -148,6 +148,10 @@ def __init__(
                 ssl_credentials=ssl_credentials,
                 scopes=scopes or self.AUTH_SCOPES,
                 quota_project_id=quota_project_id,
+                options=[
+                    ("grpc.max_send_message_length", -1),
+                    ("grpc.max_receive_message_length", -1),
+                ],
             )
             self._ssl_channel_credentials = ssl_credentials
         else:
@@ -166,9 +170,14 @@ def __init__(
                 ssl_credentials=ssl_channel_credentials,
                 scopes=scopes or self.AUTH_SCOPES,
                 quota_project_id=quota_project_id,
+                options=[
+                    ("grpc.max_send_message_length", -1),
+                    ("grpc.max_receive_message_length", -1),
+                ],
             )
 
         self._stubs = {}  # type: Dict[str, Callable]
+        self._operations_client = None
 
         # Run the base constructor.
         super().__init__(
@@ -192,7 +201,7 @@ def create_channel(
     ) -> grpc.Channel:
         """Create and return a gRPC channel object.
         Args:
-            address (Optionsl[str]): The host for the channel to use.
+            address (Optional[str]): The host for the channel to use.
             credentials (Optional[~.Credentials]): The
                 authorization credentials to attach to requests. These
                 credentials identify this application to the service. If
@@ -239,13 +248,11 @@ def operations_client(self) -> operations_v1.OperationsClient:
         client.
         """
         # Sanity check: Only create a new client if we do not already have one.
-        if "operations_client" not in self.__dict__:
-            self.__dict__["operations_client"] = operations_v1.OperationsClient(
-                self.grpc_channel
-            )
+        if self._operations_client is None:
+            self._operations_client = operations_v1.OperationsClient(self.grpc_channel)
 
         # Return the client from cache.
-        return self.__dict__["operations_client"]
+        return self._operations_client
 
     @property
     def annotate_video(

google/cloud/videointelligence_v1/services/video_intelligence_service/transports/grpc_asyncio.py

@@ -193,6 +193,10 @@ def __init__(
                 ssl_credentials=ssl_credentials,
                 scopes=scopes or self.AUTH_SCOPES,
                 quota_project_id=quota_project_id,
+                options=[
+                    ("grpc.max_send_message_length", -1),
+                    ("grpc.max_receive_message_length", -1),
+                ],
             )
             self._ssl_channel_credentials = ssl_credentials
         else:
@@ -211,6 +215,10 @@ def __init__(
                 ssl_credentials=ssl_channel_credentials,
                 scopes=scopes or self.AUTH_SCOPES,
                 quota_project_id=quota_project_id,
+                options=[
+                    ("grpc.max_send_message_length", -1),
+                    ("grpc.max_receive_message_length", -1),
+                ],
             )
 
         # Run the base constructor.
@@ -224,6 +232,7 @@ def __init__(
         )
 
         self._stubs = {}
+        self._operations_client = None
 
     @property
     def grpc_channel(self) -> aio.Channel:
@@ -243,13 +252,13 @@ def operations_client(self) -> operations_v1.OperationsAsyncClient:
         client.
         """
         # Sanity check: Only create a new client if we do not already have one.
-        if "operations_client" not in self.__dict__:
-            self.__dict__["operations_client"] = operations_v1.OperationsAsyncClient(
+        if self._operations_client is None:
+            self._operations_client = operations_v1.OperationsAsyncClient(
                 self.grpc_channel
             )
 
         # Return the client from cache.
-        return self.__dict__["operations_client"]
+        return self._operations_client
 
     @property
     def annotate_video(

google/cloud/videointelligence_v1/types/__init__.py

@@ -59,9 +59,11 @@
     ObjectTrackingFrame,
     ObjectTrackingAnnotation,
     LogoRecognitionAnnotation,
+    Feature,
+    LabelDetectionMode,
+    Likelihood,
 )
 
-
 __all__ = (
     "AnnotateVideoRequest",
     "VideoContext",
@@ -106,4 +108,7 @@
     "ObjectTrackingFrame",
     "ObjectTrackingAnnotation",
     "LogoRecognitionAnnotation",
+    "Feature",
+    "LabelDetectionMode",
+    "Likelihood",
 )

google/cloud/videointelligence_v1beta2/services/video_intelligence_service/transports/__init__.py

@@ -30,7 +30,6 @@
 _transport_registry["grpc"] = VideoIntelligenceServiceGrpcTransport
 _transport_registry["grpc_asyncio"] = VideoIntelligenceServiceGrpcAsyncIOTransport
 
-
 __all__ = (
     "VideoIntelligenceServiceTransport",
     "VideoIntelligenceServiceGrpcTransport",

google/cloud/videointelligence_v1beta2/services/video_intelligence_service/transports/grpc.py

@@ -148,6 +148,10 @@ def __init__(
                 ssl_credentials=ssl_credentials,
                 scopes=scopes or self.AUTH_SCOPES,
                 quota_project_id=quota_project_id,
+                options=[
+                    ("grpc.max_send_message_length", -1),
+                    ("grpc.max_receive_message_length", -1),
+                ],
             )
             self._ssl_channel_credentials = ssl_credentials
         else:
@@ -166,9 +170,14 @@ def __init__(
                 ssl_credentials=ssl_channel_credentials,
                 scopes=scopes or self.AUTH_SCOPES,
                 quota_project_id=quota_project_id,
+                options=[
+                    ("grpc.max_send_message_length", -1),
+                    ("grpc.max_receive_message_length", -1),
+                ],
             )
 
         self._stubs = {}  # type: Dict[str, Callable]
+        self._operations_client = None
 
         # Run the base constructor.
         super().__init__(
@@ -192,7 +201,7 @@ def create_channel(
     ) -> grpc.Channel:
         """Create and return a gRPC channel object.
         Args:
-            address (Optionsl[str]): The host for the channel to use.
+            address (Optional[str]): The host for the channel to use.
             credentials (Optional[~.Credentials]): The
                 authorization credentials to attach to requests. These
                 credentials identify this application to the service. If
@@ -239,13 +248,11 @@ def operations_client(self) -> operations_v1.OperationsClient:
         client.
         """
         # Sanity check: Only create a new client if we do not already have one.
-        if "operations_client" not in self.__dict__:
-            self.__dict__["operations_client"] = operations_v1.OperationsClient(
-                self.grpc_channel
-            )
+        if self._operations_client is None:
+            self._operations_client = operations_v1.OperationsClient(self.grpc_channel)
 
         # Return the client from cache.
-        return self.__dict__["operations_client"]
+        return self._operations_client
 
     @property
     def annotate_video(

google/cloud/videointelligence_v1beta2/services/video_intelligence_service/transports/grpc_asyncio.py

@@ -193,6 +193,10 @@ def __init__(
                 ssl_credentials=ssl_credentials,
                 scopes=scopes or self.AUTH_SCOPES,
                 quota_project_id=quota_project_id,
+                options=[
+                    ("grpc.max_send_message_length", -1),
+                    ("grpc.max_receive_message_length", -1),
+                ],
             )
             self._ssl_channel_credentials = ssl_credentials
         else:
@@ -211,6 +215,10 @@ def __init__(
                 ssl_credentials=ssl_channel_credentials,
                 scopes=scopes or self.AUTH_SCOPES,
                 quota_project_id=quota_project_id,
+                options=[
+                    ("grpc.max_send_message_length", -1),
+                    ("grpc.max_receive_message_length", -1),
+                ],
             )
 
         # Run the base constructor.
@@ -224,6 +232,7 @@ def __init__(
         )
 
         self._stubs = {}
+        self._operations_client = None
 
     @property
     def grpc_channel(self) -> aio.Channel:
@@ -243,13 +252,13 @@ def operations_client(self) -> operations_v1.OperationsAsyncClient:
         client.
         """
         # Sanity check: Only create a new client if we do not already have one.
-        if "operations_client" not in self.__dict__:
-            self.__dict__["operations_client"] = operations_v1.OperationsAsyncClient(
+        if self._operations_client is None:
+            self._operations_client = operations_v1.OperationsAsyncClient(
                 self.grpc_channel
             )
 
         # Return the client from cache.
-        return self.__dict__["operations_client"]
+        return self._operations_client
 
     @property
     def annotate_video(

google/cloud/videointelligence_v1beta2/types/__init__.py

@@ -37,9 +37,11 @@
     AnnotateVideoResponse,
     VideoAnnotationProgress,
     AnnotateVideoProgress,
+    Feature,
+    LabelDetectionMode,
+    Likelihood,
 )
 
-
 __all__ = (
     "AnnotateVideoRequest",
     "VideoContext",
@@ -62,4 +64,7 @@
     "AnnotateVideoResponse",
     "VideoAnnotationProgress",
     "AnnotateVideoProgress",
+    "Feature",
+    "LabelDetectionMode",
+    "Likelihood",
 )

google/cloud/videointelligence_v1p1beta1/services/video_intelligence_service/transports/__init__.py

@@ -30,7 +30,6 @@
 _transport_registry["grpc"] = VideoIntelligenceServiceGrpcTransport
 _transport_registry["grpc_asyncio"] = VideoIntelligenceServiceGrpcAsyncIOTransport
 
-
 __all__ = (
     "VideoIntelligenceServiceTransport",
     "VideoIntelligenceServiceGrpcTransport",

google/cloud/videointelligence_v1p1beta1/services/video_intelligence_service/transports/grpc.py

@@ -148,6 +148,10 @@ def __init__(
                 ssl_credentials=ssl_credentials,
                 scopes=scopes or self.AUTH_SCOPES,
                 quota_project_id=quota_project_id,
+                options=[
+                    ("grpc.max_send_message_length", -1),
+                    ("grpc.max_receive_message_length", -1),
+                ],
             )
             self._ssl_channel_credentials = ssl_credentials
         else:
@@ -166,9 +170,14 @@ def __init__(
                 ssl_credentials=ssl_channel_credentials,
                 scopes=scopes or self.AUTH_SCOPES,
                 quota_project_id=quota_project_id,
+                options=[
+                    ("grpc.max_send_message_length", -1),
+                    ("grpc.max_receive_message_length", -1),
+                ],
             )
 
         self._stubs = {}  # type: Dict[str, Callable]
+        self._operations_client = None
 
         # Run the base constructor.
         super().__init__(
@@ -192,7 +201,7 @@ def create_channel(
     ) -> grpc.Channel:
         """Create and return a gRPC channel object.
         Args:
-            address (Optionsl[str]): The host for the channel to use.
+            address (Optional[str]): The host for the channel to use.
             credentials (Optional[~.Credentials]): The
                 authorization credentials to attach to requests. These
                 credentials identify this application to the service. If
@@ -239,13 +248,11 @@ def operations_client(self) -> operations_v1.OperationsClient:
         client.
         """
         # Sanity check: Only create a new client if we do not already have one.
-        if "operations_client" not in self.__dict__:
-            self.__dict__["operations_client"] = operations_v1.OperationsClient(
-                self.grpc_channel
-            )
+        if self._operations_client is None:
+            self._operations_client = operations_v1.OperationsClient(self.grpc_channel)
 
         # Return the client from cache.
-        return self.__dict__["operations_client"]
+        return self._operations_client
 
     @property
     def annotate_video(

google/cloud/videointelligence_v1p1beta1/services/video_intelligence_service/transports/grpc_asyncio.py

@@ -193,6 +193,10 @@ def __init__(
                 ssl_credentials=ssl_credentials,
                 scopes=scopes or self.AUTH_SCOPES,
                 quota_project_id=quota_project_id,
+                options=[
+                    ("grpc.max_send_message_length", -1),
+                    ("grpc.max_receive_message_length", -1),
+                ],
             )
             self._ssl_channel_credentials = ssl_credentials
         else:
@@ -211,6 +215,10 @@ def __init__(
                 ssl_credentials=ssl_channel_credentials,
                 scopes=scopes or self.AUTH_SCOPES,
                 quota_project_id=quota_project_id,
+                options=[
+                    ("grpc.max_send_message_length", -1),
+                    ("grpc.max_receive_message_length", -1),
+                ],
             )
 
         # Run the base constructor.
@@ -224,6 +232,7 @@ def __init__(
         )
 
         self._stubs = {}
+        self._operations_client = None
 
     @property
     def grpc_channel(self) -> aio.Channel:
@@ -243,13 +252,13 @@ def operations_client(self) -> operations_v1.OperationsAsyncClient:
         client.
         """
         # Sanity check: Only create a new client if we do not already have one.
-        if "operations_client" not in self.__dict__:
-            self.__dict__["operations_client"] = operations_v1.OperationsAsyncClient(
+        if self._operations_client is None:
+            self._operations_client = operations_v1.OperationsAsyncClient(
                 self.grpc_channel
             )
 
         # Return the client from cache.
-        return self.__dict__["operations_client"]
+        return self._operations_client
 
     @property
     def annotate_video(

google/cloud/videointelligence_v1p1beta1/types/__init__.py

@@ -37,9 +37,11 @@
     SpeechTranscription,
     SpeechRecognitionAlternative,
     WordInfo,
+    Feature,
+    LabelDetectionMode,
+    Likelihood,
 )
 
-
 __all__ = (
     "AnnotateVideoRequest",
     "VideoContext",
@@ -62,4 +64,7 @@
     "SpeechTranscription",
     "SpeechRecognitionAlternative",
     "WordInfo",
+    "Feature",
+    "LabelDetectionMode",
+    "Likelihood",
 )

google/cloud/videointelligence_v1p2beta1/services/video_intelligence_service/transports/__init__.py

@@ -30,7 +30,6 @@
 _transport_registry["grpc"] = VideoIntelligenceServiceGrpcTransport
 _transport_registry["grpc_asyncio"] = VideoIntelligenceServiceGrpcAsyncIOTransport
 
-
 __all__ = (
     "VideoIntelligenceServiceTransport",
     "VideoIntelligenceServiceGrpcTransport",