[synapse-artifacts] release for composite-v5 (Azure#26170)

* code

* update

* Packaging update of azure-synapse-artifacts

* update

* Packaging update of azure-synapse-artifacts

* update dependency for ci

* changelog

* Packaging update of azure-synapse-artifacts

* update

* Update _version.py

* test

* Update CHANGELOG.md

* Update CHANGELOG.md

Co-authored-by: Azure SDK Bot <[email protected]>
Co-authored-by: Jiefeng Chen (WICRESOFT NORTH AMERICA LTD) <[email protected]>

Author: 3 people

sdk/synapse/azure-synapse-artifacts/CHANGELOG.md

@@ -1,14 +1,14 @@
 # Release History
 
-## 0.13.1 (Unreleased)
+## 0.14.0 (2022-09-19)
 
 ### Features Added
 
-### Breaking Changes
-
-### Bugs Fixed
+  - Upgraded api-version for some operation group
 
 ### Other Changes
+  
+  - Drop support for python3.6
 
 ## 0.13.0 (2022-04-21)
 

sdk/synapse/azure-synapse-artifacts/LICENSE

@@ -18,4 +18,4 @@ FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE
 AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
 LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
 OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE
-SOFTWARE.
+SOFTWARE.

sdk/synapse/azure-synapse-artifacts/MANIFEST.in

@@ -1,7 +1,8 @@
-recursive-include tests *.py *.yaml
+include _meta.json
+recursive-include tests *.py *.json
 recursive-include samples *.py *.md
 include *.md
-include LICENSE
 include azure/__init__.py
 include azure/synapse/__init__.py
+include LICENSE
 include azure/synapse/artifacts/py.typed

sdk/synapse/azure-synapse-artifacts/README.md

@@ -1,7 +1,7 @@
 # Microsoft Azure SDK for Python
 
 This is the Microsoft Azure Synapse Artifacts Client Library.
-This package has been tested with Python 3.6, 3.7, 3.8, 3.9 and 3.10.
+This package has been tested with Python 3.7+.
 For a more complete view of Azure libraries, see the [azure sdk python release](https://aka.ms/azsdk/python/all).
 
 ## _Disclaimer_
@@ -16,6 +16,7 @@ For code examples, see [Synapse Artifacts](https://docs.microsoft.com/python/api
 
 If you encounter any bugs or have suggestions, please file an issue in the
 [Issues](https://github.com/Azure/azure-sdk-for-python/issues)
-section of the project.
+section of the project. 
+
 
 ![Impressions](https://azure-sdk-impressions.azurewebsites.net/api/impressions/azure-sdk-for-python%2Fazure-synapse-artifacts%2FREADME.png)

sdk/synapse/azure-synapse-artifacts/azure/__init__.py

@@ -1 +1 @@
-__path__ = __import__('pkgutil').extend_path(__path__, __name__)
+__path__ = __import__("pkgutil").extend_path(__path__, __name__)

sdk/synapse/azure-synapse-artifacts/azure/synapse/__init__.py

@@ -1 +1 @@
-__path__ = __import__('pkgutil').extend_path(__path__, __name__)
+__path__ = __import__("pkgutil").extend_path(__path__, __name__)

sdk/synapse/azure-synapse-artifacts/azure/synapse/artifacts/__init__.py

@@ -17,7 +17,8 @@
 except ImportError:
     _patch_all = []
 from ._patch import patch_sdk as _patch_sdk
-__all__ = ['ArtifactsClient']
+
+__all__ = ["ArtifactsClient"]
 __all__.extend([p for p in _patch_all if p not in __all__])
 
 _patch_sdk()

sdk/synapse/azure-synapse-artifacts/azure/synapse/artifacts/_artifacts_client.py

@@ -9,20 +9,44 @@
 from copy import deepcopy
 from typing import Any, TYPE_CHECKING
 
-from msrest import Deserializer, Serializer
-
 from azure.core import PipelineClient
 from azure.core.rest import HttpRequest, HttpResponse
 
 from . import models
 from ._configuration import ArtifactsClientConfiguration
-from .operations import BigDataPoolsOperations, DataFlowDebugSessionOperations, DataFlowOperations, DatasetOperations, IntegrationRuntimesOperations, KqlScriptOperations, KqlScriptsOperations, LibraryOperations, LinkConnectionOperations, LinkedServiceOperations, MetastoreOperations, NotebookOperationResultOperations, NotebookOperations, PipelineOperations, PipelineRunOperations, SparkConfigurationOperations, SparkJobDefinitionOperations, SqlPoolsOperations, SqlScriptOperations, TriggerOperations, TriggerRunOperations, WorkspaceGitRepoManagementOperations, WorkspaceOperations
+from ._serialization import Deserializer, Serializer
+from .operations import (
+    BigDataPoolsOperations,
+    DataFlowDebugSessionOperations,
+    DataFlowOperations,
+    DatasetOperations,
+    IntegrationRuntimesOperations,
+    KqlScriptOperations,
+    KqlScriptsOperations,
+    LibraryOperations,
+    LinkConnectionOperations,
+    LinkedServiceOperations,
+    MetastoreOperations,
+    NotebookOperationResultOperations,
+    NotebookOperations,
+    PipelineOperations,
+    PipelineRunOperations,
+    SparkConfigurationOperations,
+    SparkJobDefinitionOperations,
+    SqlPoolsOperations,
+    SqlScriptOperations,
+    TriggerOperations,
+    TriggerRunOperations,
+    WorkspaceGitRepoManagementOperations,
+    WorkspaceOperations,
+)
 
 if TYPE_CHECKING:
     # pylint: disable=unused-import,ungrouped-imports
     from azure.core.credentials import TokenCredential
 
-class ArtifactsClient:    # pylint: disable=too-many-instance-attributes
+
+class ArtifactsClient:  # pylint: disable=client-accepts-api-version-keyword,too-many-instance-attributes
     """ArtifactsClient.
 
     :ivar link_connection: LinkConnectionOperations operations
@@ -74,105 +98,61 @@ class ArtifactsClient:    # pylint: disable=too-many-instance-attributes
     :vartype trigger_run: azure.synapse.artifacts.operations.TriggerRunOperations
     :ivar workspace: WorkspaceOperations operations
     :vartype workspace: azure.synapse.artifacts.operations.WorkspaceOperations
-    :param credential: Credential needed for the client to connect to Azure.
+    :param credential: Credential needed for the client to connect to Azure. Required.
     :type credential: ~azure.core.credentials.TokenCredential
     :param endpoint: The workspace development endpoint, for example
-     https://myworkspace.dev.azuresynapse.net.
+     https://myworkspace.dev.azuresynapse.net. Required.
     :type endpoint: str
     :keyword int polling_interval: Default waiting time between two polls for LRO operations if no
      Retry-After header is present.
     """
 
-    def __init__(
-        self,
-        credential: "TokenCredential",
-        endpoint: str,
-        **kwargs: Any
-    ) -> None:
-        _base_url = '{endpoint}'
+    def __init__(self, credential: "TokenCredential", endpoint: str, **kwargs: Any) -> None:
+        _endpoint = "{endpoint}"
         self._config = ArtifactsClientConfiguration(credential=credential, endpoint=endpoint, **kwargs)
-        self._client = PipelineClient(base_url=_base_url, config=self._config, **kwargs)
+        self._client = PipelineClient(base_url=_endpoint, config=self._config, **kwargs)
 
         client_models = {k: v for k, v in models.__dict__.items() if isinstance(v, type)}
         self._serialize = Serializer(client_models)
         self._deserialize = Deserializer(client_models)
         self._serialize.client_side_validation = False
-        self.link_connection = LinkConnectionOperations(
-            self._client, self._config, self._serialize, self._deserialize
-        )
-        self.kql_scripts = KqlScriptsOperations(
-            self._client, self._config, self._serialize, self._deserialize
-        )
-        self.kql_script = KqlScriptOperations(
-            self._client, self._config, self._serialize, self._deserialize
-        )
-        self.metastore = MetastoreOperations(
-            self._client, self._config, self._serialize, self._deserialize
-        )
+        self.link_connection = LinkConnectionOperations(self._client, self._config, self._serialize, self._deserialize)
+        self.kql_scripts = KqlScriptsOperations(self._client, self._config, self._serialize, self._deserialize)
+        self.kql_script = KqlScriptOperations(self._client, self._config, self._serialize, self._deserialize)
+        self.metastore = MetastoreOperations(self._client, self._config, self._serialize, self._deserialize)
         self.spark_configuration = SparkConfigurationOperations(
             self._client, self._config, self._serialize, self._deserialize
         )
-        self.big_data_pools = BigDataPoolsOperations(
-            self._client, self._config, self._serialize, self._deserialize
-        )
-        self.data_flow = DataFlowOperations(
-            self._client, self._config, self._serialize, self._deserialize
-        )
+        self.big_data_pools = BigDataPoolsOperations(self._client, self._config, self._serialize, self._deserialize)
+        self.data_flow = DataFlowOperations(self._client, self._config, self._serialize, self._deserialize)
         self.data_flow_debug_session = DataFlowDebugSessionOperations(
             self._client, self._config, self._serialize, self._deserialize
         )
-        self.dataset = DatasetOperations(
-            self._client, self._config, self._serialize, self._deserialize
-        )
+        self.dataset = DatasetOperations(self._client, self._config, self._serialize, self._deserialize)
         self.workspace_git_repo_management = WorkspaceGitRepoManagementOperations(
             self._client, self._config, self._serialize, self._deserialize
         )
         self.integration_runtimes = IntegrationRuntimesOperations(
             self._client, self._config, self._serialize, self._deserialize
         )
-        self.library = LibraryOperations(
-            self._client, self._config, self._serialize, self._deserialize
-        )
-        self.linked_service = LinkedServiceOperations(
-            self._client, self._config, self._serialize, self._deserialize
-        )
-        self.notebook = NotebookOperations(
-            self._client, self._config, self._serialize, self._deserialize
-        )
+        self.library = LibraryOperations(self._client, self._config, self._serialize, self._deserialize)
+        self.linked_service = LinkedServiceOperations(self._client, self._config, self._serialize, self._deserialize)
+        self.notebook = NotebookOperations(self._client, self._config, self._serialize, self._deserialize)
         self.notebook_operation_result = NotebookOperationResultOperations(
             self._client, self._config, self._serialize, self._deserialize
         )
-        self.pipeline = PipelineOperations(
-            self._client, self._config, self._serialize, self._deserialize
-        )
-        self.pipeline_run = PipelineRunOperations(
-            self._client, self._config, self._serialize, self._deserialize
-        )
+        self.pipeline = PipelineOperations(self._client, self._config, self._serialize, self._deserialize)
+        self.pipeline_run = PipelineRunOperations(self._client, self._config, self._serialize, self._deserialize)
         self.spark_job_definition = SparkJobDefinitionOperations(
             self._client, self._config, self._serialize, self._deserialize
         )
-        self.sql_pools = SqlPoolsOperations(
-            self._client, self._config, self._serialize, self._deserialize
-        )
-        self.sql_script = SqlScriptOperations(
-            self._client, self._config, self._serialize, self._deserialize
-        )
-        self.trigger = TriggerOperations(
-            self._client, self._config, self._serialize, self._deserialize
-        )
-        self.trigger_run = TriggerRunOperations(
-            self._client, self._config, self._serialize, self._deserialize
-        )
-        self.workspace = WorkspaceOperations(
-            self._client, self._config, self._serialize, self._deserialize
-        )
-
+        self.sql_pools = SqlPoolsOperations(self._client, self._config, self._serialize, self._deserialize)
+        self.sql_script = SqlScriptOperations(self._client, self._config, self._serialize, self._deserialize)
+        self.trigger = TriggerOperations(self._client, self._config, self._serialize, self._deserialize)
+        self.trigger_run = TriggerRunOperations(self._client, self._config, self._serialize, self._deserialize)
+        self.workspace = WorkspaceOperations(self._client, self._config, self._serialize, self._deserialize)
 
-    def _send_request(
-        self,
-        request: HttpRequest,
-        **kwargs: Any
-    ) -> HttpResponse:
+    def _send_request(self, request: HttpRequest, **kwargs: Any) -> HttpResponse:
         """Runs the network request through the client's chained policies.
 
         >>> from azure.core.rest import HttpRequest
@@ -181,7 +161,7 @@ def _send_request(
         >>> response = client._send_request(request)
         <HttpResponse: 200 OK>
 
-        For more information on this code flow, see https://aka.ms/azsdk/python/protocol/quickstart
+        For more information on this code flow, see https://aka.ms/azsdk/dpcodegen/python/send_request
 
         :param request: The network request you want to make. Required.
         :type request: ~azure.core.rest.HttpRequest
@@ -192,7 +172,7 @@ def _send_request(
 
         request_copy = deepcopy(request)
         path_format_arguments = {
-            "endpoint": self._serialize.url("self._config.endpoint", self._config.endpoint, 'str', skip_quote=True),
+            "endpoint": self._serialize.url("self._config.endpoint", self._config.endpoint, "str", skip_quote=True),
         }
 
         request_copy.url = self._client.format_url(request_copy.url, **path_format_arguments)

sdk/synapse/azure-synapse-artifacts/azure/synapse/artifacts/_configuration.py

@@ -24,19 +24,14 @@ class ArtifactsClientConfiguration(Configuration):  # pylint: disable=too-many-i
     Note that all parameters used to create this instance are saved as instance
     attributes.
 
-    :param credential: Credential needed for the client to connect to Azure.
+    :param credential: Credential needed for the client to connect to Azure. Required.
     :type credential: ~azure.core.credentials.TokenCredential
     :param endpoint: The workspace development endpoint, for example
-     https://myworkspace.dev.azuresynapse.net.
+     https://myworkspace.dev.azuresynapse.net. Required.
     :type endpoint: str
     """
 
-    def __init__(
-        self,
-        credential: "TokenCredential",
-        endpoint: str,
-        **kwargs: Any
-    ) -> None:
+    def __init__(self, credential: "TokenCredential", endpoint: str, **kwargs: Any) -> None:
         super(ArtifactsClientConfiguration, self).__init__(**kwargs)
         if credential is None:
             raise ValueError("Parameter 'credential' must not be None.")
@@ -45,23 +40,24 @@ def __init__(
 
         self.credential = credential
         self.endpoint = endpoint
-        self.credential_scopes = kwargs.pop('credential_scopes', ['https://dev.azuresynapse.net/.default'])
-        kwargs.setdefault('sdk_moniker', 'synapse-artifacts/{}'.format(VERSION))
+        self.credential_scopes = kwargs.pop("credential_scopes", ["https://dev.azuresynapse.net/.default"])
+        kwargs.setdefault("sdk_moniker", "synapse-artifacts/{}".format(VERSION))
         self._configure(**kwargs)
 
     def _configure(
-        self,
-        **kwargs  # type: Any
+        self, **kwargs  # type: Any
     ):
         # type: (...) -> None
-        self.user_agent_policy = kwargs.get('user_agent_policy') or policies.UserAgentPolicy(**kwargs)
-        self.headers_policy = kwargs.get('headers_policy') or policies.HeadersPolicy(**kwargs)
-        self.proxy_policy = kwargs.get('proxy_policy') or policies.ProxyPolicy(**kwargs)
-        self.logging_policy = kwargs.get('logging_policy') or policies.NetworkTraceLoggingPolicy(**kwargs)
-        self.http_logging_policy = kwargs.get('http_logging_policy') or policies.HttpLoggingPolicy(**kwargs)
-        self.retry_policy = kwargs.get('retry_policy') or policies.RetryPolicy(**kwargs)
-        self.custom_hook_policy = kwargs.get('custom_hook_policy') or policies.CustomHookPolicy(**kwargs)
-        self.redirect_policy = kwargs.get('redirect_policy') or policies.RedirectPolicy(**kwargs)
-        self.authentication_policy = kwargs.get('authentication_policy')
+        self.user_agent_policy = kwargs.get("user_agent_policy") or policies.UserAgentPolicy(**kwargs)
+        self.headers_policy = kwargs.get("headers_policy") or policies.HeadersPolicy(**kwargs)
+        self.proxy_policy = kwargs.get("proxy_policy") or policies.ProxyPolicy(**kwargs)
+        self.logging_policy = kwargs.get("logging_policy") or policies.NetworkTraceLoggingPolicy(**kwargs)
+        self.http_logging_policy = kwargs.get("http_logging_policy") or policies.HttpLoggingPolicy(**kwargs)
+        self.retry_policy = kwargs.get("retry_policy") or policies.RetryPolicy(**kwargs)
+        self.custom_hook_policy = kwargs.get("custom_hook_policy") or policies.CustomHookPolicy(**kwargs)
+        self.redirect_policy = kwargs.get("redirect_policy") or policies.RedirectPolicy(**kwargs)
+        self.authentication_policy = kwargs.get("authentication_policy")
         if self.credential and not self.authentication_policy:
-            self.authentication_policy = policies.BearerTokenCredentialPolicy(self.credential, *self.credential_scopes, **kwargs)
+            self.authentication_policy = policies.BearerTokenCredentialPolicy(
+                self.credential, *self.credential_scopes, **kwargs
+            )

sdk/synapse/azure-synapse-artifacts/azure/synapse/artifacts/_patch.py

@@ -28,4 +28,4 @@
 # This file is used for handwritten extensions to the generated code. Example:
 # https://github.com/Azure/azure-sdk-for-python/blob/main/doc/dev/customize_code/how-to-patch-sdk-code.md
 def patch_sdk():
-    pass
+    pass