Oct release (Azure#20890)

* Oct release * update spark
zihzhan-msft · Sep 29, 2021 · 1a3ad63 · 1a3ad63
1 parent 6216cd9
commit 1a3ad63
Show file tree

Hide file tree

Showing 128 changed files with 5,099 additions and 102,463 deletions.
diff --git a/sdk/synapse/azure-synapse-artifacts/CHANGELOG.md b/sdk/synapse/azure-synapse-artifacts/CHANGELOG.md
@@ -1,14 +1,10 @@
 # Release History
 
-## 0.9.0 (Unreleased)
+## 0.9.0 (2021-10-05)
 
 ### Features Added
 
-### Breaking Changes
-
-### Bugs Fixed
-
-### Other Changes
+- re-generated based on tag package-artifacts-composite-v1
 
 ## 0.8.0 (2021-08-10)
 

diff --git a/sdk/synapse/azure-synapse-artifacts/azure/synapse/artifacts/__init__.py b/sdk/synapse/azure-synapse-artifacts/azure/synapse/artifacts/__init__.py
@@ -7,6 +7,9 @@
 # --------------------------------------------------------------------------
 
 from ._artifacts_client import ArtifactsClient
+from ._version import VERSION
+
+__version__ = VERSION
 __all__ = ['ArtifactsClient']
 
 try:

diff --git a/sdk/synapse/azure-synapse-artifacts/azure/synapse/artifacts/_artifacts_client.py b/sdk/synapse/azure-synapse-artifacts/azure/synapse/artifacts/_artifacts_client.py
diff --git a/sdk/synapse/azure-synapse-artifacts/azure/synapse/artifacts/_configuration.py b/sdk/synapse/azure-synapse-artifacts/azure/synapse/artifacts/_configuration.py
@@ -1,13 +1,11 @@
 # coding=utf-8
 # --------------------------------------------------------------------------
 # Copyright (c) Microsoft Corporation. All rights reserved.
-# Licensed under the MIT License. See License.txt in the project root for
-# license information.
-#
+# Licensed under the MIT License. See License.txt in the project root for license information.
 # Code generated by Microsoft (R) AutoRest Code Generator.
-# Changes may cause incorrect behavior and will be lost if the code is
-# regenerated.
+# Changes may cause incorrect behavior and will be lost if the code is regenerated.
 # --------------------------------------------------------------------------
+
 from typing import TYPE_CHECKING
 
 from azure.core.configuration import Configuration
@@ -21,6 +19,7 @@
 
     from azure.core.credentials import TokenCredential
 
+
 class ArtifactsClientConfiguration(Configuration):
     """Configuration for ArtifactsClient.
 
@@ -49,7 +48,7 @@ def __init__(
         self.credential = credential
         self.endpoint = endpoint
         self.credential_scopes = kwargs.pop('credential_scopes', ['https://dev.azuresynapse.net/.default'])
-        kwargs.setdefault('sdk_moniker', 'azure-synapse-artifacts/{}'.format(VERSION))
+        kwargs.setdefault('sdk_moniker', 'synapse-artifacts/{}'.format(VERSION))
         self._configure(**kwargs)
 
     def _configure(

diff --git a/sdk/synapse/azure-synapse-artifacts/azure/synapse/artifacts/aio/_artifacts_client.py b/sdk/synapse/azure-synapse-artifacts/azure/synapse/artifacts/aio/_artifacts_client.py
diff --git a/sdk/synapse/azure-synapse-artifacts/azure/synapse/artifacts/aio/_configuration.py b/sdk/synapse/azure-synapse-artifacts/azure/synapse/artifacts/aio/_configuration.py
@@ -1,13 +1,11 @@
 # coding=utf-8
 # --------------------------------------------------------------------------
 # Copyright (c) Microsoft Corporation. All rights reserved.
-# Licensed under the MIT License. See License.txt in the project root for
-# license information.
-#
+# Licensed under the MIT License. See License.txt in the project root for license information.
 # Code generated by Microsoft (R) AutoRest Code Generator.
-# Changes may cause incorrect behavior and will be lost if the code is
-# regenerated.
+# Changes may cause incorrect behavior and will be lost if the code is regenerated.
 # --------------------------------------------------------------------------
+
 from typing import Any, TYPE_CHECKING
 
 from azure.core.configuration import Configuration
@@ -19,6 +17,7 @@
     # pylint: disable=unused-import,ungrouped-imports
     from azure.core.credentials_async import AsyncTokenCredential
 
+
 class ArtifactsClientConfiguration(Configuration):
     """Configuration for ArtifactsClient.
 
@@ -35,7 +34,7 @@ def __init__(
         self,
         credential: "AsyncTokenCredential",
         endpoint: str,
-        **kwargs  # type: Any
+        **kwargs: Any
     ) -> None:
         if credential is None:
             raise ValueError("Parameter 'credential' must not be None.")
@@ -46,7 +45,7 @@ def __init__(
         self.credential = credential
         self.endpoint = endpoint
         self.credential_scopes = kwargs.pop('credential_scopes', ['https://dev.azuresynapse.net/.default'])
-        kwargs.setdefault('sdk_moniker', 'azure-synapse-artifacts/{}'.format(VERSION))
+        kwargs.setdefault('sdk_moniker', 'synapse-artifacts/{}'.format(VERSION))
         self._configure(**kwargs)
 
     def _configure(

diff --git a/...2021_06_01_preview/operations/__init__.py → ...apse/artifacts/aio/operations/__init__.py b/...2021_06_01_preview/operations/__init__.py → ...apse/artifacts/aio/operations/__init__.py
@@ -6,48 +6,48 @@
 # Changes may cause incorrect behavior and will be lost if the code is regenerated.
 # --------------------------------------------------------------------------
 
-from ._linked_service_operations import LinkedServiceOperations
-from ._dataset_operations import DatasetOperations
-from ._pipeline_operations import PipelineOperations
-from ._pipeline_run_operations import PipelineRunOperations
-from ._trigger_operations import TriggerOperations
-from ._trigger_run_operations import TriggerRunOperations
-from ._data_flow_operations import DataFlowOperations
-from ._data_flow_debug_session_operations import DataFlowDebugSessionOperations
-from ._sql_script_operations import SqlScriptOperations
-from ._spark_job_definition_operations import SparkJobDefinitionOperations
-from ._notebook_operations import NotebookOperations
-from ._notebook_operation_result_operations import NotebookOperationResultOperations
+from ._kql_scripts_operations import KqlScriptsOperations
+from ._kql_script_operations import KqlScriptOperations
 from ._spark_configuration_operations import SparkConfigurationOperations
 from ._big_data_pools_operations import BigDataPoolsOperations
+from ._data_flow_operations import DataFlowOperations
+from ._data_flow_debug_session_operations import DataFlowDebugSessionOperations
+from ._dataset_operations import DatasetOperations
 from ._workspace_git_repo_management_operations import WorkspaceGitRepoManagementOperations
 from ._integration_runtimes_operations import IntegrationRuntimesOperations
 from ._library_operations import LibraryOperations
-from ._operation_result_operations import OperationResultOperations
-from ._operation_status_operations import OperationStatusOperations
+from ._linked_service_operations import LinkedServiceOperations
+from ._notebook_operations import NotebookOperations
+from ._notebook_operation_result_operations import NotebookOperationResultOperations
+from ._pipeline_operations import PipelineOperations
+from ._pipeline_run_operations import PipelineRunOperations
+from ._spark_job_definition_operations import SparkJobDefinitionOperations
 from ._sql_pools_operations import SqlPoolsOperations
+from ._sql_script_operations import SqlScriptOperations
+from ._trigger_operations import TriggerOperations
+from ._trigger_run_operations import TriggerRunOperations
 from ._workspace_operations import WorkspaceOperations
 
 __all__ = [
-    'LinkedServiceOperations',
-    'DatasetOperations',
-    'PipelineOperations',
-    'PipelineRunOperations',
-    'TriggerOperations',
-    'TriggerRunOperations',
-    'DataFlowOperations',
-    'DataFlowDebugSessionOperations',
-    'SqlScriptOperations',
-    'SparkJobDefinitionOperations',
-    'NotebookOperations',
-    'NotebookOperationResultOperations',
+    'KqlScriptsOperations',
+    'KqlScriptOperations',
     'SparkConfigurationOperations',
     'BigDataPoolsOperations',
+    'DataFlowOperations',
+    'DataFlowDebugSessionOperations',
+    'DatasetOperations',
     'WorkspaceGitRepoManagementOperations',
     'IntegrationRuntimesOperations',
     'LibraryOperations',
-    'OperationResultOperations',
-    'OperationStatusOperations',
+    'LinkedServiceOperations',
+    'NotebookOperations',
+    'NotebookOperationResultOperations',
+    'PipelineOperations',
+    'PipelineRunOperations',
+    'SparkJobDefinitionOperations',
     'SqlPoolsOperations',
+    'SqlScriptOperations',
+    'TriggerOperations',
+    'TriggerRunOperations',
     'WorkspaceOperations',
 ]
diff --git a/.../operations/_big_data_pools_operations.py → .../operations/_big_data_pools_operations.py b/.../operations/_big_data_pools_operations.py → .../operations/_big_data_pools_operations.py
@@ -24,7 +24,7 @@ class BigDataPoolsOperations:
     instantiates it for you and attaches it as an attribute.
 
     :ivar models: Alias to model classes used in this operation group.
-    :type models: ~azure.synapse.artifacts.v2020_12_01.models
+    :type models: ~azure.synapse.artifacts.models
     :param client: Client for service requests.
     :param config: Configuration of service client.
     :param serializer: An object model serializer.
@@ -47,7 +47,7 @@ async def list(
 
         :keyword callable cls: A custom type or function that will be passed the direct response
         :return: BigDataPoolResourceInfoListResult, or the result of cls(response)
-        :rtype: ~azure.synapse.artifacts.v2020_12_01.models.BigDataPoolResourceInfoListResult
+        :rtype: ~azure.synapse.artifacts.models.BigDataPoolResourceInfoListResult
         :raises: ~azure.core.exceptions.HttpResponseError
         """
         cls = kwargs.pop('cls', None)  # type: ClsType["_models.BigDataPoolResourceInfoListResult"]
@@ -101,7 +101,7 @@ async def get(
         :type big_data_pool_name: str
         :keyword callable cls: A custom type or function that will be passed the direct response
         :return: BigDataPoolResourceInfo, or the result of cls(response)
-        :rtype: ~azure.synapse.artifacts.v2020_12_01.models.BigDataPoolResourceInfo
+        :rtype: ~azure.synapse.artifacts.models.BigDataPoolResourceInfo
         :raises: ~azure.core.exceptions.HttpResponseError
         """
         cls = kwargs.pop('cls', None)  # type: ClsType["_models.BigDataPoolResourceInfo"]

diff --git a/...ns/_data_flow_debug_session_operations.py → ...ns/_data_flow_debug_session_operations.py b/...ns/_data_flow_debug_session_operations.py → ...ns/_data_flow_debug_session_operations.py
@@ -27,7 +27,7 @@ class DataFlowDebugSessionOperations:
     instantiates it for you and attaches it as an attribute.
 
     :ivar models: Alias to model classes used in this operation group.
-    :type models: ~azure.synapse.artifacts.v2020_12_01.models
+    :type models: ~azure.synapse.artifacts.models
     :param client: Client for service requests.
     :param config: Configuration of service client.
     :param serializer: An object model serializer.
@@ -81,7 +81,7 @@ async def _create_data_flow_debug_session_initial(
 
         if response.status_code not in [200, 202]:
             map_error(status_code=response.status_code, response=response, error_map=error_map)
-            error = self._deserialize.failsafe_deserialize(_models.CloudError, response)
+            error = self._deserialize.failsafe_deserialize(_models.CloudErrorAutoGenerated, response)
             raise HttpResponseError(response=response, model=error)
 
         response_headers = {}
@@ -106,15 +106,15 @@ async def begin_create_data_flow_debug_session(
         """Creates a data flow debug session.
 
         :param request: Data flow debug session definition.
-        :type request: ~azure.synapse.artifacts.v2020_12_01.models.CreateDataFlowDebugSessionRequest
+        :type request: ~azure.synapse.artifacts.models.CreateDataFlowDebugSessionRequest
         :keyword callable cls: A custom type or function that will be passed the direct response
         :keyword str continuation_token: A continuation token to restart a poller from a saved state.
         :keyword polling: By default, your polling method will be AsyncLROBasePolling.
          Pass in False for this operation to not poll, or pass in your own initialized polling object for a personal polling strategy.
         :paramtype polling: bool or ~azure.core.polling.AsyncPollingMethod
         :keyword int polling_interval: Default waiting time between two polls for LRO operations if no Retry-After header is present.
         :return: An instance of AsyncLROPoller that returns either CreateDataFlowDebugSessionResponse or the result of cls(response)
-        :rtype: ~azure.core.polling.AsyncLROPoller[~azure.synapse.artifacts.v2020_12_01.models.CreateDataFlowDebugSessionResponse]
+        :rtype: ~azure.core.polling.AsyncLROPoller[~azure.synapse.artifacts.models.CreateDataFlowDebugSessionResponse]
         :raises ~azure.core.exceptions.HttpResponseError:
         """
         polling = kwargs.pop('polling', True)  # type: Union[bool, AsyncPollingMethod]
@@ -167,7 +167,7 @@ def query_data_flow_debug_sessions_by_workspace(
 
         :keyword callable cls: A custom type or function that will be passed the direct response
         :return: An iterator like instance of either QueryDataFlowDebugSessionsResponse or the result of cls(response)
-        :rtype: ~azure.core.async_paging.AsyncItemPaged[~azure.synapse.artifacts.v2020_12_01.models.QueryDataFlowDebugSessionsResponse]
+        :rtype: ~azure.core.async_paging.AsyncItemPaged[~azure.synapse.artifacts.models.QueryDataFlowDebugSessionsResponse]
         :raises: ~azure.core.exceptions.HttpResponseError
         """
         cls = kwargs.pop('cls', None)  # type: ClsType["_models.QueryDataFlowDebugSessionsResponse"]
@@ -219,7 +219,7 @@ async def get_next(next_link=None):
             response = pipeline_response.http_response
 
             if response.status_code not in [200]:
-                error = self._deserialize.failsafe_deserialize(_models.CloudError, response)
+                error = self._deserialize.failsafe_deserialize(_models.CloudErrorAutoGenerated, response)
                 map_error(status_code=response.status_code, response=response, error_map=error_map)
                 raise HttpResponseError(response=response, model=error)
 
@@ -238,10 +238,10 @@ async def add_data_flow(
         """Add a data flow into debug session.
 
         :param request: Data flow debug session definition with debug content.
-        :type request: ~azure.synapse.artifacts.v2020_12_01.models.DataFlowDebugPackage
+        :type request: ~azure.synapse.artifacts.models.DataFlowDebugPackage
         :keyword callable cls: A custom type or function that will be passed the direct response
         :return: AddDataFlowToDebugSessionResponse, or the result of cls(response)
-        :rtype: ~azure.synapse.artifacts.v2020_12_01.models.AddDataFlowToDebugSessionResponse
+        :rtype: ~azure.synapse.artifacts.models.AddDataFlowToDebugSessionResponse
         :raises: ~azure.core.exceptions.HttpResponseError
         """
         cls = kwargs.pop('cls', None)  # type: ClsType["_models.AddDataFlowToDebugSessionResponse"]
@@ -278,7 +278,7 @@ async def add_data_flow(
 
         if response.status_code not in [200]:
             map_error(status_code=response.status_code, response=response, error_map=error_map)
-            error = self._deserialize.failsafe_deserialize(_models.CloudError, response)
+            error = self._deserialize.failsafe_deserialize(_models.CloudErrorAutoGenerated, response)
             raise HttpResponseError(response=response, model=error)
 
         deserialized = self._deserialize('AddDataFlowToDebugSessionResponse', pipeline_response)
@@ -297,7 +297,7 @@ async def delete_data_flow_debug_session(
         """Deletes a data flow debug session.
 
         :param request: Data flow debug session definition for deletion.
-        :type request: ~azure.synapse.artifacts.v2020_12_01.models.DeleteDataFlowDebugSessionRequest
+        :type request: ~azure.synapse.artifacts.models.DeleteDataFlowDebugSessionRequest
         :keyword callable cls: A custom type or function that will be passed the direct response
         :return: None, or the result of cls(response)
         :rtype: None
@@ -337,7 +337,7 @@ async def delete_data_flow_debug_session(
 
         if response.status_code not in [200]:
             map_error(status_code=response.status_code, response=response, error_map=error_map)
-            error = self._deserialize.failsafe_deserialize(_models.CloudError, response)
+            error = self._deserialize.failsafe_deserialize(_models.CloudErrorAutoGenerated, response)
             raise HttpResponseError(response=response, model=error)
 
         if cls:
@@ -384,7 +384,7 @@ async def _execute_command_initial(
 
         if response.status_code not in [200, 202]:
             map_error(status_code=response.status_code, response=response, error_map=error_map)
-            error = self._deserialize.failsafe_deserialize(_models.CloudError, response)
+            error = self._deserialize.failsafe_deserialize(_models.CloudErrorAutoGenerated, response)
             raise HttpResponseError(response=response, model=error)
 
         response_headers = {}
@@ -409,15 +409,15 @@ async def begin_execute_command(
         """Execute a data flow debug command.
 
         :param request: Data flow debug command definition.
-        :type request: ~azure.synapse.artifacts.v2020_12_01.models.DataFlowDebugCommandRequest
+        :type request: ~azure.synapse.artifacts.models.DataFlowDebugCommandRequest
         :keyword callable cls: A custom type or function that will be passed the direct response
         :keyword str continuation_token: A continuation token to restart a poller from a saved state.
         :keyword polling: By default, your polling method will be AsyncLROBasePolling.
          Pass in False for this operation to not poll, or pass in your own initialized polling object for a personal polling strategy.
         :paramtype polling: bool or ~azure.core.polling.AsyncPollingMethod
         :keyword int polling_interval: Default waiting time between two polls for LRO operations if no Retry-After header is present.
         :return: An instance of AsyncLROPoller that returns either DataFlowDebugCommandResponse or the result of cls(response)
-        :rtype: ~azure.core.polling.AsyncLROPoller[~azure.synapse.artifacts.v2020_12_01.models.DataFlowDebugCommandResponse]
+        :rtype: ~azure.core.polling.AsyncLROPoller[~azure.synapse.artifacts.models.DataFlowDebugCommandResponse]
         :raises ~azure.core.exceptions.HttpResponseError:
         """
         polling = kwargs.pop('polling', True)  # type: Union[bool, AsyncPollingMethod]