[SchemaRegistry] pylint (#40709)

* lint

* [SchemaRegistry] lint

* add _utils

* fix verifytypes

Author: swathipil

sdk/schemaregistry/azure-schemaregistry-avroencoder/azure/schemaregistry/encoder/avroencoder/aio/_async_lru.py

@@ -29,7 +29,7 @@
 # 2. The last update to the library was a year ago, so it seems the library is
 #    not being actively maintained.
 
-import asyncio
+import asyncio # pylint:disable=do-not-import-asyncio
 from collections import OrderedDict
 from functools import _CacheInfo, _make_key, partial, wraps
 

sdk/schemaregistry/azure-schemaregistry/apiview-properties.json

@@ -0,0 +1,6 @@
+{
+    "CrossLanguagePackageId": "SchemaRegistry",
+    "CrossLanguageDefinitionId": {
+        "azure.schemaregistry.models.SchemaContentTypeValues": "SchemaRegistry.SchemaContentTypeValues"
+    }
+}

sdk/schemaregistry/azure-schemaregistry/azure/schemaregistry/__init__.py

@@ -12,7 +12,6 @@
 if TYPE_CHECKING:
     from ._patch import *  # pylint: disable=unused-wildcard-import
 
-from ._client import SchemaRegistryClient  # type: ignore
 from ._version import VERSION
 
 __version__ = VERSION

sdk/schemaregistry/azure-schemaregistry/azure/schemaregistry/_client.py

@@ -16,7 +16,7 @@
 
 from ._configuration import SchemaRegistryClientConfiguration
 from ._operations import SchemaRegistryClientOperationsMixin
-from ._serialization import Deserializer, Serializer
+from ._utils.serialization import Deserializer, Serializer
 
 if TYPE_CHECKING:
     from azure.core.credentials import TokenCredential
@@ -41,6 +41,7 @@ def __init__(self, fully_qualified_namespace: str, credential: "TokenCredential"
         self._config = SchemaRegistryClientConfiguration(
             fully_qualified_namespace=fully_qualified_namespace, credential=credential, **kwargs
         )
+
         _policies = kwargs.pop("policies", None)
         if _policies is None:
             _policies = [

sdk/schemaregistry/azure-schemaregistry/azure/schemaregistry/_model_base.py

@@ -633,7 +633,7 @@ def _deserialize(cls, data, exist_discriminators):
                 discriminator_value = data.find(xml_name).text  # pyright: ignore
         else:
             discriminator_value = data.get(discriminator._rest_name)
-        mapped_cls = cls.__mapping__.get(discriminator_value, cls)  # pyright: ignore
+        mapped_cls = cls.__mapping__.get(discriminator_value, cls)  # pyright: ignore # pylint: disable=no-member
         return mapped_cls._deserialize(data, exist_discriminators)
 
     def as_dict(self, *, exclude_readonly: bool = False) -> typing.Dict[str, typing.Any]:

sdk/schemaregistry/azure-schemaregistry/azure/schemaregistry/_operations/_operations.py

@@ -5,11 +5,11 @@
 # Code generated by Microsoft (R) Python Code Generator.
 # Changes may cause incorrect behavior and will be lost if the code is regenerated.
 # --------------------------------------------------------------------------
-import json # pylint: disable=unused-import
-import sys
+from collections.abc import MutableMapping
 from typing import Any, Callable, Dict, Iterable, Iterator, List, Optional, TypeVar
 import urllib.parse
 
+from azure.core import PipelineClient
 from azure.core.exceptions import (
     ClientAuthenticationError,
     HttpResponseError,
@@ -26,14 +26,11 @@
 from azure.core.tracing.decorator import distributed_trace
 from azure.core.utils import case_insensitive_dict
 
-from .._model_base import SdkJSONEncoder, _deserialize # pylint: disable=unused-import
-from .._serialization import Serializer
-from .._vendor import SchemaRegistryClientMixinABC
+from .._configuration import SchemaRegistryClientConfiguration
+from .._utils.model_base import _deserialize
+from .._utils.serialization import Serializer
+from .._utils.utils import ClientMixinABC
 
-if sys.version_info >= (3, 9):
-    from collections.abc import MutableMapping
-else:
-    from typing import MutableMapping  # type: ignore
 T = TypeVar("T")
 ClsType = Optional[Callable[[PipelineResponse[HttpRequest, HttpResponse], T, Dict[str, Any]], Any]]
 
@@ -201,7 +198,7 @@ def build_schema_registry_register_schema_request(  # pylint: disable=name-too-l
     return HttpRequest(method="PUT", url=_url, params=_params, headers=_headers, **kwargs)
 
 
-class SchemaRegistryClientOperationsMixin(SchemaRegistryClientMixinABC):
+class SchemaRegistryClientOperationsMixin(ClientMixinABC[PipelineClient, SchemaRegistryClientConfiguration]):
 
     @distributed_trace
     def _list_schema_groups(self, **kwargs: Any) -> Iterable[str]:
@@ -271,7 +268,7 @@ def prepare_request(next_link=None):
 
         def extract_data(pipeline_response):
             deserialized = pipeline_response.http_response.json()
-            list_of_elem = _deserialize(List[str], deserialized["Value"])
+            list_of_elem = _deserialize(List[str], deserialized.get("Value", []))
             if cls:
                 list_of_elem = cls(list_of_elem)  # type: ignore
             return deserialized.get("NextLink") or None, iter(list_of_elem)
@@ -367,7 +364,7 @@ def prepare_request(next_link=None):
 
         def extract_data(pipeline_response):
             deserialized = pipeline_response.http_response.json()
-            list_of_elem = _deserialize(List[int], deserialized["Value"])
+            list_of_elem = _deserialize(List[int], deserialized.get("Value", []))
             if cls:
                 list_of_elem = cls(list_of_elem)  # type: ignore
             return deserialized.get("NextLink") or None, iter(list_of_elem)

sdk/schemaregistry/azure-schemaregistry/azure/schemaregistry/_operations/_patch.py

@@ -96,7 +96,7 @@ class SchemaRegistryClientOperationsMixin(GeneratedClientOperationsMixin):
     """
 
     @distributed_trace
-    def _get_schema_properties_by_content( # type: ignore[override] # pylint: disable=inconsistent-return-statements
+    def _get_schema_properties_by_content(  # type: ignore[override] # pylint: disable=inconsistent-return-statements
         self,
         group_name: str,
         schema_name: str,
@@ -186,7 +186,7 @@ def _get_schema_properties_by_content( # type: ignore[override] # pylint: disabl
             return cls(pipeline_response, None, response_headers)
 
     @distributed_trace
-    def _register_schema(   # type: ignore[override]    # pylint: disable=inconsistent-return-statements
+    def _register_schema(  # type: ignore[override]    # pylint: disable=inconsistent-return-statements
         self,
         group_name: str,
         schema_name: str,

sdk/schemaregistry/azure-schemaregistry/azure/schemaregistry/_patch.py

@@ -1,3 +1,4 @@
+# pylint: disable=line-too-long,useless-suppression
 # ------------------------------------
 # Copyright (c) Microsoft Corporation.
 # Licensed under the MIT License.

sdk/schemaregistry/azure-schemaregistry/azure/schemaregistry/_serialization.py

@@ -1,4 +1,4 @@
-# pylint: disable=too-many-lines
+# pylint: disable=too-many-lines,line-too-long,useless-suppression
 # --------------------------------------------------------------------------
 #
 # Copyright (c) Microsoft Corporation. All rights reserved.

sdk/schemaregistry/azure-schemaregistry/azure/schemaregistry/_utils/__init__.py

@@ -0,0 +1,6 @@
+# --------------------------------------------------------------------------
+# Copyright (c) Microsoft Corporation. All rights reserved.
+# Licensed under the MIT License. See License.txt in the project root for license information.
+# Code generated by Microsoft (R) Python Code Generator.
+# Changes may cause incorrect behavior and will be lost if the code is regenerated.
+# --------------------------------------------------------------------------