synapse artifacts jan updates

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

@@ -1,12 +1,10 @@
 # Release History
 
-## 0.11.0 (Unreleased)
+## 0.11.0 (2022-01-11)
 
 ### Features Added
 
-### Breaking Changes
-
-### Bugs Fixed
+- Added `MetastoreOperations`
 
 ### Other Changes
 

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

@@ -12,8 +12,7 @@
 __version__ = VERSION
 __all__ = ['ArtifactsClient']
 
-try:
-    from ._patch import patch_sdk  # type: ignore
-    patch_sdk()
-except ImportError:
-    pass
+# `._patch.py` 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
+from ._patch import patch_sdk
+patch_sdk()

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

@@ -14,7 +14,7 @@
 
 from . import models
 from ._configuration import ArtifactsClientConfiguration
-from .operations import BigDataPoolsOperations, DataFlowDebugSessionOperations, DataFlowOperations, DatasetOperations, IntegrationRuntimesOperations, KqlScriptOperations, KqlScriptsOperations, LibraryOperations, LinkedServiceOperations, NotebookOperationResultOperations, NotebookOperations, PipelineOperations, PipelineRunOperations, SparkConfigurationOperations, SparkJobDefinitionOperations, SqlPoolsOperations, SqlScriptOperations, TriggerOperations, TriggerRunOperations, WorkspaceGitRepoManagementOperations, WorkspaceOperations
+from .operations import BigDataPoolsOperations, DataFlowDebugSessionOperations, DataFlowOperations, DatasetOperations, IntegrationRuntimesOperations, KqlScriptOperations, KqlScriptsOperations, LibraryOperations, LinkedServiceOperations, MetastoreOperations, NotebookOperationResultOperations, NotebookOperations, PipelineOperations, PipelineRunOperations, SparkConfigurationOperations, SparkJobDefinitionOperations, SqlPoolsOperations, SqlScriptOperations, TriggerOperations, TriggerRunOperations, WorkspaceGitRepoManagementOperations, WorkspaceOperations
 
 if TYPE_CHECKING:
     # pylint: disable=unused-import,ungrouped-imports
@@ -30,6 +30,8 @@ class ArtifactsClient(object):
     :vartype kql_scripts: azure.synapse.artifacts.operations.KqlScriptsOperations
     :ivar kql_script: KqlScriptOperations operations
     :vartype kql_script: azure.synapse.artifacts.operations.KqlScriptOperations
+    :ivar metastore: MetastoreOperations operations
+    :vartype metastore: azure.synapse.artifacts.operations.MetastoreOperations
     :ivar spark_configuration: SparkConfigurationOperations operations
     :vartype spark_configuration: azure.synapse.artifacts.operations.SparkConfigurationOperations
     :ivar big_data_pools: BigDataPoolsOperations operations
@@ -97,6 +99,7 @@ def __init__(
         self._serialize.client_side_validation = False
         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)

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

@@ -0,0 +1,31 @@
+# coding=utf-8
+# --------------------------------------------------------------------------
+#
+# Copyright (c) Microsoft Corporation. All rights reserved.
+#
+# The MIT License (MIT)
+#
+# Permission is hereby granted, free of charge, to any person obtaining a copy
+# of this software and associated documentation files (the ""Software""), to
+# deal in the Software without restriction, including without limitation the
+# rights to use, copy, modify, merge, publish, distribute, sublicense, and/or
+# sell copies of the Software, and to permit persons to whom the Software is
+# furnished to do so, subject to the following conditions:
+#
+# The above copyright notice and this permission notice shall be included in
+# all copies or substantial portions of the Software.
+#
+# THE SOFTWARE IS PROVIDED *AS IS*, WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
+# IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
+# 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.
+#
+# --------------------------------------------------------------------------
+
+# 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

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

@@ -9,8 +9,7 @@
 from ._artifacts_client import ArtifactsClient
 __all__ = ['ArtifactsClient']
 
-try:
-    from ._patch import patch_sdk  # type: ignore
-    patch_sdk()
-except ImportError:
-    pass
+# `._patch.py` 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
+from ._patch import patch_sdk
+patch_sdk()

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

@@ -15,7 +15,7 @@
 
 from .. import models
 from ._configuration import ArtifactsClientConfiguration
-from .operations import BigDataPoolsOperations, DataFlowDebugSessionOperations, DataFlowOperations, DatasetOperations, IntegrationRuntimesOperations, KqlScriptOperations, KqlScriptsOperations, LibraryOperations, LinkedServiceOperations, NotebookOperationResultOperations, NotebookOperations, PipelineOperations, PipelineRunOperations, SparkConfigurationOperations, SparkJobDefinitionOperations, SqlPoolsOperations, SqlScriptOperations, TriggerOperations, TriggerRunOperations, WorkspaceGitRepoManagementOperations, WorkspaceOperations
+from .operations import BigDataPoolsOperations, DataFlowDebugSessionOperations, DataFlowOperations, DatasetOperations, IntegrationRuntimesOperations, KqlScriptOperations, KqlScriptsOperations, LibraryOperations, LinkedServiceOperations, MetastoreOperations, NotebookOperationResultOperations, NotebookOperations, PipelineOperations, PipelineRunOperations, SparkConfigurationOperations, SparkJobDefinitionOperations, SqlPoolsOperations, SqlScriptOperations, TriggerOperations, TriggerRunOperations, WorkspaceGitRepoManagementOperations, WorkspaceOperations
 
 if TYPE_CHECKING:
     # pylint: disable=unused-import,ungrouped-imports
@@ -28,6 +28,8 @@ class ArtifactsClient:
     :vartype kql_scripts: azure.synapse.artifacts.aio.operations.KqlScriptsOperations
     :ivar kql_script: KqlScriptOperations operations
     :vartype kql_script: azure.synapse.artifacts.aio.operations.KqlScriptOperations
+    :ivar metastore: MetastoreOperations operations
+    :vartype metastore: azure.synapse.artifacts.aio.operations.MetastoreOperations
     :ivar spark_configuration: SparkConfigurationOperations operations
     :vartype spark_configuration:
      azure.synapse.artifacts.aio.operations.SparkConfigurationOperations
@@ -97,6 +99,7 @@ def __init__(
         self._serialize.client_side_validation = False
         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)

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

@@ -0,0 +1,31 @@
+# coding=utf-8
+# --------------------------------------------------------------------------
+#
+# Copyright (c) Microsoft Corporation. All rights reserved.
+#
+# The MIT License (MIT)
+#
+# Permission is hereby granted, free of charge, to any person obtaining a copy
+# of this software and associated documentation files (the ""Software""), to
+# deal in the Software without restriction, including without limitation the
+# rights to use, copy, modify, merge, publish, distribute, sublicense, and/or
+# sell copies of the Software, and to permit persons to whom the Software is
+# furnished to do so, subject to the following conditions:
+#
+# The above copyright notice and this permission notice shall be included in
+# all copies or substantial portions of the Software.
+#
+# THE SOFTWARE IS PROVIDED *AS IS*, WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
+# IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
+# 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.
+#
+# --------------------------------------------------------------------------
+
+# 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

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

@@ -8,6 +8,7 @@
 
 from ._kql_scripts_operations import KqlScriptsOperations
 from ._kql_script_operations import KqlScriptOperations
+from ._metastore_operations import MetastoreOperations
 from ._spark_configuration_operations import SparkConfigurationOperations
 from ._big_data_pools_operations import BigDataPoolsOperations
 from ._data_flow_operations import DataFlowOperations
@@ -31,6 +32,7 @@
 __all__ = [
     'KqlScriptsOperations',
     'KqlScriptOperations',
+    'MetastoreOperations',
     'SparkConfigurationOperations',
     'BigDataPoolsOperations',
     'DataFlowOperations',

sdk/synapse/azure-synapse-artifacts/azure/synapse/artifacts/aio/operations/_data_flow_debug_session_operations.py

@@ -61,12 +61,12 @@ async def _create_data_flow_debug_session_initial(
         api_version = kwargs.pop('api_version', "2020-12-01")  # type: str
         content_type = kwargs.pop('content_type', "application/json")  # type: Optional[str]
 
-        json = self._serialize.body(request, 'CreateDataFlowDebugSessionRequest')
+        _json = self._serialize.body(request, 'CreateDataFlowDebugSessionRequest')
 
         request = build_create_data_flow_debug_session_request_initial(
             api_version=api_version,
             content_type=content_type,
-            json=json,
+            json=_json,
             template_url=self._create_data_flow_debug_session_initial.metadata['url'],
         )
         request = _convert_request(request)
@@ -280,12 +280,12 @@ async def add_data_flow(
         api_version = kwargs.pop('api_version', "2020-12-01")  # type: str
         content_type = kwargs.pop('content_type', "application/json")  # type: Optional[str]
 
-        json = self._serialize.body(request, 'DataFlowDebugPackage')
+        _json = self._serialize.body(request, 'DataFlowDebugPackage')
 
         request = build_add_data_flow_request(
             api_version=api_version,
             content_type=content_type,
-            json=json,
+            json=_json,
             template_url=self.add_data_flow.metadata['url'],
         )
         request = _convert_request(request)
@@ -339,12 +339,12 @@ async def delete_data_flow_debug_session(
         api_version = kwargs.pop('api_version', "2020-12-01")  # type: str
         content_type = kwargs.pop('content_type', "application/json")  # type: Optional[str]
 
-        json = self._serialize.body(request, 'DeleteDataFlowDebugSessionRequest')
+        _json = self._serialize.body(request, 'DeleteDataFlowDebugSessionRequest')
 
         request = build_delete_data_flow_debug_session_request(
             api_version=api_version,
             content_type=content_type,
-            json=json,
+            json=_json,
             template_url=self.delete_data_flow_debug_session.metadata['url'],
         )
         request = _convert_request(request)
@@ -381,12 +381,12 @@ async def _execute_command_initial(
         api_version = kwargs.pop('api_version', "2020-12-01")  # type: str
         content_type = kwargs.pop('content_type', "application/json")  # type: Optional[str]
 
-        json = self._serialize.body(request, 'DataFlowDebugCommandRequest')
+        _json = self._serialize.body(request, 'DataFlowDebugCommandRequest')
 
         request = build_execute_command_request_initial(
             api_version=api_version,
             content_type=content_type,
-            json=json,
+            json=_json,
             template_url=self._execute_command_initial.metadata['url'],
         )
         request = _convert_request(request)

sdk/synapse/azure-synapse-artifacts/azure/synapse/artifacts/aio/operations/_data_flow_operations.py

@@ -64,13 +64,13 @@ async def _create_or_update_data_flow_initial(
         content_type = kwargs.pop('content_type', "application/json")  # type: Optional[str]
 
         _data_flow = _models.DataFlowResource(properties=properties)
-        json = self._serialize.body(_data_flow, 'DataFlowResource')
+        _json = self._serialize.body(_data_flow, 'DataFlowResource')
 
         request = build_create_or_update_data_flow_request_initial(
             data_flow_name=data_flow_name,
             api_version=api_version,
             content_type=content_type,
-            json=json,
+            json=_json,
             if_match=if_match,
             template_url=self._create_or_update_data_flow_initial.metadata['url'],
         )
@@ -361,13 +361,13 @@ async def _rename_data_flow_initial(
         content_type = kwargs.pop('content_type', "application/json")  # type: Optional[str]
 
         _request = _models.ArtifactRenameRequest(new_name=new_name)
-        json = self._serialize.body(_request, 'ArtifactRenameRequest')
+        _json = self._serialize.body(_request, 'ArtifactRenameRequest')
 
         request = build_rename_data_flow_request_initial(
             data_flow_name=data_flow_name,
             api_version=api_version,
             content_type=content_type,
-            json=json,
+            json=_json,
             template_url=self._rename_data_flow_initial.metadata['url'],
         )
         request = _convert_request(request)

sdk/synapse/azure-synapse-artifacts/azure/synapse/artifacts/aio/operations/_dataset_operations.py

@@ -144,13 +144,13 @@ async def _create_or_update_dataset_initial(
         content_type = kwargs.pop('content_type', "application/json")  # type: Optional[str]
 
         _dataset = _models.DatasetResource(properties=properties)
-        json = self._serialize.body(_dataset, 'DatasetResource')
+        _json = self._serialize.body(_dataset, 'DatasetResource')
 
         request = build_create_or_update_dataset_request_initial(
             dataset_name=dataset_name,
             api_version=api_version,
             content_type=content_type,
-            json=json,
+            json=_json,
             if_match=if_match,
             template_url=self._create_or_update_dataset_initial.metadata['url'],
         )
@@ -443,13 +443,13 @@ async def _rename_dataset_initial(
         content_type = kwargs.pop('content_type', "application/json")  # type: Optional[str]
 
         _request = _models.ArtifactRenameRequest(new_name=new_name)
-        json = self._serialize.body(_request, 'ArtifactRenameRequest')
+        _json = self._serialize.body(_request, 'ArtifactRenameRequest')
 
         request = build_rename_dataset_request_initial(
             dataset_name=dataset_name,
             api_version=api_version,
             content_type=content_type,
-            json=json,
+            json=_json,
             template_url=self._rename_dataset_initial.metadata['url'],
         )
         request = _convert_request(request)

sdk/synapse/azure-synapse-artifacts/azure/synapse/artifacts/aio/operations/_kql_script_operations.py

@@ -60,13 +60,13 @@ async def _create_or_update_initial(
         api_version = kwargs.pop('api_version', "2021-11-01-preview")  # type: str
         content_type = kwargs.pop('content_type', "application/json")  # type: Optional[str]
 
-        json = self._serialize.body(kql_script, 'KqlScriptResource')
+        _json = self._serialize.body(kql_script, 'KqlScriptResource')
 
         request = build_create_or_update_request_initial(
             kql_script_name=kql_script_name,
             api_version=api_version,
             content_type=content_type,
-            json=json,
+            json=_json,
             template_url=self._create_or_update_initial.metadata['url'],
         )
         request = _convert_request(request)
@@ -346,13 +346,13 @@ async def _rename_initial(
         content_type = kwargs.pop('content_type', "application/json")  # type: Optional[str]
 
         _rename_request = _models.ArtifactRenameRequest(new_name=new_name)
-        json = self._serialize.body(_rename_request, 'ArtifactRenameRequest')
+        _json = self._serialize.body(_rename_request, 'ArtifactRenameRequest')
 
         request = build_rename_request_initial(
             kql_script_name=kql_script_name,
             api_version=api_version,
             content_type=content_type,
-            json=json,
+            json=_json,
             template_url=self._rename_initial.metadata['url'],
         )
         request = _convert_request(request)

sdk/synapse/azure-synapse-artifacts/azure/synapse/artifacts/aio/operations/_library_operations.py

@@ -634,14 +634,14 @@ async def append(
         api_version = kwargs.pop('api_version', "2020-12-01")  # type: str
         content_type = kwargs.pop('content_type', "application/octet-stream")  # type: Optional[str]
 
-        content = content
+        _content = content
 
         request = build_append_request(
             library_name=library_name,
             comp=comp,
             api_version=api_version,
             content_type=content_type,
-            content=content,
+            content=_content,
             blob_condition_append_position=blob_condition_append_position,
             template_url=self.append.metadata['url'],
         )

sdk/synapse/azure-synapse-artifacts/azure/synapse/artifacts/aio/operations/_linked_service_operations.py

@@ -145,13 +145,13 @@ async def _create_or_update_linked_service_initial(
         content_type = kwargs.pop('content_type', "application/json")  # type: Optional[str]
 
         _linked_service = _models.LinkedServiceResource(properties=properties)
-        json = self._serialize.body(_linked_service, 'LinkedServiceResource')
+        _json = self._serialize.body(_linked_service, 'LinkedServiceResource')
 
         request = build_create_or_update_linked_service_request_initial(
             linked_service_name=linked_service_name,
             api_version=api_version,
             content_type=content_type,
-            json=json,
+            json=_json,
             if_match=if_match,
             template_url=self._create_or_update_linked_service_initial.metadata['url'],
         )
@@ -446,13 +446,13 @@ async def _rename_linked_service_initial(
         content_type = kwargs.pop('content_type', "application/json")  # type: Optional[str]
 
         _request = _models.ArtifactRenameRequest(new_name=new_name)
-        json = self._serialize.body(_request, 'ArtifactRenameRequest')
+        _json = self._serialize.body(_request, 'ArtifactRenameRequest')
 
         request = build_rename_linked_service_request_initial(
             linked_service_name=linked_service_name,
             api_version=api_version,
             content_type=content_type,
-            json=json,
+            json=_json,
             template_url=self._rename_linked_service_initial.metadata['url'],
         )
         request = _convert_request(request)