[AutoPR azure-mgmt-datashare] Add stable version for Data Share and in place sharing support for Kusto

sdk/datashare/azure-mgmt-datashare/azure/mgmt/datashare/_data_share_management_client.py

@@ -74,7 +74,7 @@ def __init__(
         super(DataShareManagementClient, self).__init__(self.config.credentials, self.config)
 
         client_models = {k: v for k, v in models.__dict__.items() if isinstance(v, type)}
-        self.api_version = '2018-11-01-preview'
+        self.api_version = '2019-11-01'
         self._serialize = Serializer(client_models)
         self._deserialize = Deserializer(client_models)
 

sdk/datashare/azure-mgmt-datashare/azure/mgmt/datashare/models/__init__.py

@@ -36,6 +36,10 @@
     from ._models_py3 import DimensionProperties
     from ._models_py3 import Identity
     from ._models_py3 import Invitation
+    from ._models_py3 import KustoClusterDataSet
+    from ._models_py3 import KustoClusterDataSetMapping
+    from ._models_py3 import KustoDatabaseDataSet
+    from ._models_py3 import KustoDatabaseDataSetMapping
     from ._models_py3 import OperationMetaLogSpecification
     from ._models_py3 import OperationMetaMetricSpecification
     from ._models_py3 import OperationMetaServiceSpecification
@@ -87,6 +91,10 @@
     from ._models import DimensionProperties
     from ._models import Identity
     from ._models import Invitation
+    from ._models import KustoClusterDataSet
+    from ._models import KustoClusterDataSetMapping
+    from ._models import KustoDatabaseDataSet
+    from ._models import KustoDatabaseDataSetMapping
     from ._models import OperationMetaLogSpecification
     from ._models import OperationMetaMetricSpecification
     from ._models import OperationMetaServiceSpecification
@@ -133,9 +141,9 @@
     Status,
     InvitationStatus,
     ShareKind,
+    SynchronizationMode,
     DataSetType,
     ShareSubscriptionStatus,
-    SynchronizationMode,
     RecurrenceInterval,
     TriggerStatus,
     DataSetMappingStatus,
@@ -169,6 +177,10 @@
     'DimensionProperties',
     'Identity',
     'Invitation',
+    'KustoClusterDataSet',
+    'KustoClusterDataSetMapping',
+    'KustoDatabaseDataSet',
+    'KustoDatabaseDataSetMapping',
     'OperationMetaLogSpecification',
     'OperationMetaMetricSpecification',
     'OperationMetaServiceSpecification',
@@ -203,9 +215,9 @@
     'ShareSynchronizationPaged',
     'SynchronizationDetailsPaged',
     'ProviderShareSubscriptionPaged',
+    'ShareSubscriptionPaged',
     'SourceShareSynchronizationSettingPaged',
     'ShareSubscriptionSynchronizationPaged',
-    'ShareSubscriptionPaged',
     'ConsumerSourceDataSetPaged',
     'SynchronizationSettingPaged',
     'TriggerPaged',
@@ -214,9 +226,9 @@
     'Status',
     'InvitationStatus',
     'ShareKind',
+    'SynchronizationMode',
     'DataSetType',
     'ShareSubscriptionStatus',
-    'SynchronizationMode',
     'RecurrenceInterval',
     'TriggerStatus',
     'DataSetMappingStatus',

sdk/datashare/azure-mgmt-datashare/azure/mgmt/datashare/models/_data_share_management_client_enums.py

@@ -47,6 +47,13 @@ class InvitationStatus(str, Enum):
 class ShareKind(str, Enum):
 
     copy_based = "CopyBased"
+    in_place = "InPlace"
+
+
+class SynchronizationMode(str, Enum):
+
+    incremental = "Incremental"
+    full_sync = "FullSync"
 
 
 class DataSetType(str, Enum):
@@ -59,6 +66,8 @@ class DataSetType(str, Enum):
     adls_gen2_file = "AdlsGen2File"
     adls_gen1_folder = "AdlsGen1Folder"
     adls_gen1_file = "AdlsGen1File"
+    kusto_cluster = "KustoCluster"
+    kusto_database = "KustoDatabase"
     sql_db_table = "SqlDBTable"
     sql_dw_table = "SqlDWTable"
 
@@ -71,12 +80,6 @@ class ShareSubscriptionStatus(str, Enum):
     revoking = "Revoking"
 
 
-class SynchronizationMode(str, Enum):
-
-    incremental = "Incremental"
-    full_sync = "FullSync"
-
-
 class RecurrenceInterval(str, Enum):
 
     hour = "Hour"

sdk/datashare/azure-mgmt-datashare/azure/mgmt/datashare/models/_paged_models.py

@@ -142,45 +142,45 @@ class ProviderShareSubscriptionPaged(Paged):
     def __init__(self, *args, **kwargs):
 
         super(ProviderShareSubscriptionPaged, self).__init__(*args, **kwargs)
-class SourceShareSynchronizationSettingPaged(Paged):
+class ShareSubscriptionPaged(Paged):
     """
-    A paging container for iterating over a list of :class:`SourceShareSynchronizationSetting <azure.mgmt.datashare.models.SourceShareSynchronizationSetting>` object
+    A paging container for iterating over a list of :class:`ShareSubscription <azure.mgmt.datashare.models.ShareSubscription>` object
     """
 
     _attribute_map = {
         'next_link': {'key': 'nextLink', 'type': 'str'},
-        'current_page': {'key': 'value', 'type': '[SourceShareSynchronizationSetting]'}
+        'current_page': {'key': 'value', 'type': '[ShareSubscription]'}
     }
 
     def __init__(self, *args, **kwargs):
 
-        super(SourceShareSynchronizationSettingPaged, self).__init__(*args, **kwargs)
-class ShareSubscriptionSynchronizationPaged(Paged):
+        super(ShareSubscriptionPaged, self).__init__(*args, **kwargs)
+class SourceShareSynchronizationSettingPaged(Paged):
     """
-    A paging container for iterating over a list of :class:`ShareSubscriptionSynchronization <azure.mgmt.datashare.models.ShareSubscriptionSynchronization>` object
+    A paging container for iterating over a list of :class:`SourceShareSynchronizationSetting <azure.mgmt.datashare.models.SourceShareSynchronizationSetting>` object
     """
 
     _attribute_map = {
         'next_link': {'key': 'nextLink', 'type': 'str'},
-        'current_page': {'key': 'value', 'type': '[ShareSubscriptionSynchronization]'}
+        'current_page': {'key': 'value', 'type': '[SourceShareSynchronizationSetting]'}
     }
 
     def __init__(self, *args, **kwargs):
 
-        super(ShareSubscriptionSynchronizationPaged, self).__init__(*args, **kwargs)
-class ShareSubscriptionPaged(Paged):
+        super(SourceShareSynchronizationSettingPaged, self).__init__(*args, **kwargs)
+class ShareSubscriptionSynchronizationPaged(Paged):
     """
-    A paging container for iterating over a list of :class:`ShareSubscription <azure.mgmt.datashare.models.ShareSubscription>` object
+    A paging container for iterating over a list of :class:`ShareSubscriptionSynchronization <azure.mgmt.datashare.models.ShareSubscriptionSynchronization>` object
     """
 
     _attribute_map = {
         'next_link': {'key': 'nextLink', 'type': 'str'},
-        'current_page': {'key': 'value', 'type': '[ShareSubscription]'}
+        'current_page': {'key': 'value', 'type': '[ShareSubscriptionSynchronization]'}
     }
 
     def __init__(self, *args, **kwargs):
 
-        super(ShareSubscriptionPaged, self).__init__(*args, **kwargs)
+        super(ShareSubscriptionSynchronizationPaged, self).__init__(*args, **kwargs)
 class ConsumerSourceDataSetPaged(Paged):
     """
     A paging container for iterating over a list of :class:`ConsumerSourceDataSet <azure.mgmt.datashare.models.ConsumerSourceDataSet>` object

sdk/datashare/azure-mgmt-datashare/azure/mgmt/datashare/operations/_accounts_operations.py

@@ -26,7 +26,7 @@ class AccountsOperations(object):
     :param config: Configuration of service client.
     :param serializer: An object model serializer.
     :param deserializer: An object model deserializer.
-    :ivar api_version: The api version to use. Constant value: "2018-11-01-preview".
+    :ivar api_version: The api version to use. Constant value: "2019-11-01".
     """
 
     models = models
@@ -36,7 +36,7 @@ def __init__(self, client, config, serializer, deserializer):
         self._client = client
         self._serialize = serializer
         self._deserialize = deserializer
-        self.api_version = "2018-11-01-preview"
+        self.api_version = "2019-11-01"
 
         self.config = config
 

sdk/datashare/azure-mgmt-datashare/azure/mgmt/datashare/operations/_consumer_invitations_operations.py

@@ -24,7 +24,7 @@ class ConsumerInvitationsOperations(object):
     :param config: Configuration of service client.
     :param serializer: An object model serializer.
     :param deserializer: An object model deserializer.
-    :ivar api_version: The api version to use. Constant value: "2018-11-01-preview".
+    :ivar api_version: The api version to use. Constant value: "2019-11-01".
     """
 
     models = models
@@ -34,7 +34,7 @@ def __init__(self, client, config, serializer, deserializer):
         self._client = client
         self._serialize = serializer
         self._deserialize = deserializer
-        self.api_version = "2018-11-01-preview"
+        self.api_version = "2019-11-01"
 
         self.config = config
 

sdk/datashare/azure-mgmt-datashare/azure/mgmt/datashare/operations/_consumer_source_data_sets_operations.py

@@ -24,7 +24,7 @@ class ConsumerSourceDataSetsOperations(object):
     :param config: Configuration of service client.
     :param serializer: An object model serializer.
     :param deserializer: An object model deserializer.
-    :ivar api_version: The api version to use. Constant value: "2018-11-01-preview".
+    :ivar api_version: The api version to use. Constant value: "2019-11-01".
     """
 
     models = models
@@ -34,7 +34,7 @@ def __init__(self, client, config, serializer, deserializer):
         self._client = client
         self._serialize = serializer
         self._deserialize = deserializer
-        self.api_version = "2018-11-01-preview"
+        self.api_version = "2019-11-01"
 
         self.config = config
 

sdk/datashare/azure-mgmt-datashare/azure/mgmt/datashare/operations/_data_set_mappings_operations.py

@@ -24,7 +24,7 @@ class DataSetMappingsOperations(object):
     :param config: Configuration of service client.
     :param serializer: An object model serializer.
     :param deserializer: An object model deserializer.
-    :ivar api_version: The api version to use. Constant value: "2018-11-01-preview".
+    :ivar api_version: The api version to use. Constant value: "2019-11-01".
     """
 
     models = models
@@ -34,7 +34,7 @@ def __init__(self, client, config, serializer, deserializer):
         self._client = client
         self._serialize = serializer
         self._deserialize = deserializer
-        self.api_version = "2018-11-01-preview"
+        self.api_version = "2019-11-01"
 
         self.config = config
 

sdk/datashare/azure-mgmt-datashare/azure/mgmt/datashare/operations/_data_sets_operations.py

@@ -11,6 +11,8 @@
 
 import uuid
 from msrest.pipeline import ClientRawResponse
+from msrest.polling import LROPoller, NoPolling
+from msrestazure.polling.arm_polling import ARMPolling
 
 from .. import models
 
@@ -24,7 +26,7 @@ class DataSetsOperations(object):
     :param config: Configuration of service client.
     :param serializer: An object model serializer.
     :param deserializer: An object model deserializer.
-    :ivar api_version: The api version to use. Constant value: "2018-11-01-preview".
+    :ivar api_version: The api version to use. Constant value: "2019-11-01".
     """
 
     models = models
@@ -34,7 +36,7 @@ def __init__(self, client, config, serializer, deserializer):
         self._client = client
         self._serialize = serializer
         self._deserialize = deserializer
-        self.api_version = "2018-11-01-preview"
+        self.api_version = "2019-11-01"
 
         self.config = config
 
@@ -182,30 +184,9 @@ def create(
         return deserialized
     create.metadata = {'url': '/subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/Microsoft.DataShare/accounts/{accountName}/shares/{shareName}/dataSets/{dataSetName}'}
 
-    def delete(
-            self, resource_group_name, account_name, share_name, data_set_name, custom_headers=None, raw=False, **operation_config):
-        """Delete DataSet in a share.
-
-        Delete a DataSet in a share.
 
-        :param resource_group_name: The resource group name.
-        :type resource_group_name: str
-        :param account_name: The name of the share account.
-        :type account_name: str
-        :param share_name: The name of the share.
-        :type share_name: str
-        :param data_set_name: The name of the dataSet.
-        :type data_set_name: str
-        :param dict custom_headers: headers that will be added to the request
-        :param bool raw: returns the direct response alongside the
-         deserialized response
-        :param operation_config: :ref:`Operation configuration
-         overrides<msrest:optionsforoperations>`.
-        :return: None or ClientRawResponse if raw=true
-        :rtype: None or ~msrest.pipeline.ClientRawResponse
-        :raises:
-         :class:`DataShareErrorException<azure.mgmt.datashare.models.DataShareErrorException>`
-        """
+    def _delete_initial(
+            self, resource_group_name, account_name, share_name, data_set_name, custom_headers=None, raw=False, **operation_config):
         # Construct URL
         url = self.delete.metadata['url']
         path_format_arguments = {
@@ -234,12 +215,61 @@ def delete(
         request = self._client.delete(url, query_parameters, header_parameters)
         response = self._client.send(request, stream=False, **operation_config)
 
-        if response.status_code not in [200, 204]:
+        if response.status_code not in [200, 202, 204]:
             raise models.DataShareErrorException(self._deserialize, response)
 
         if raw:
             client_raw_response = ClientRawResponse(None, response)
             return client_raw_response
+
+    def delete(
+            self, resource_group_name, account_name, share_name, data_set_name, custom_headers=None, raw=False, polling=True, **operation_config):
+        """Delete DataSet in a share.
+
+        Delete a DataSet in a share.
+
+        :param resource_group_name: The resource group name.
+        :type resource_group_name: str
+        :param account_name: The name of the share account.
+        :type account_name: str
+        :param share_name: The name of the share.
+        :type share_name: str
+        :param data_set_name: The name of the dataSet.
+        :type data_set_name: str
+        :param dict custom_headers: headers that will be added to the request
+        :param bool raw: The poller return type is ClientRawResponse, the
+         direct response alongside the deserialized response
+        :param polling: True for ARMPolling, False for no polling, or a
+         polling object for personal polling strategy
+        :return: An instance of LROPoller that returns None or
+         ClientRawResponse<None> if raw==True
+        :rtype: ~msrestazure.azure_operation.AzureOperationPoller[None] or
+         ~msrestazure.azure_operation.AzureOperationPoller[~msrest.pipeline.ClientRawResponse[None]]
+        :raises:
+         :class:`DataShareErrorException<azure.mgmt.datashare.models.DataShareErrorException>`
+        """
+        raw_result = self._delete_initial(
+            resource_group_name=resource_group_name,
+            account_name=account_name,
+            share_name=share_name,
+            data_set_name=data_set_name,
+            custom_headers=custom_headers,
+            raw=True,
+            **operation_config
+        )
+
+        def get_long_running_output(response):
+            if raw:
+                client_raw_response = ClientRawResponse(None, response)
+                return client_raw_response
+
+        lro_delay = operation_config.get(
+            'long_running_operation_timeout',
+            self.config.long_running_operation_timeout)
+        if polling is True: polling_method = ARMPolling(lro_delay, **operation_config)
+        elif polling is False: polling_method = NoPolling()
+        else: polling_method = polling
+        return LROPoller(self._client, raw_result, get_long_running_output, polling_method)
     delete.metadata = {'url': '/subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/Microsoft.DataShare/accounts/{accountName}/shares/{shareName}/dataSets/{dataSetName}'}
 
     def list_by_share(

sdk/datashare/azure-mgmt-datashare/azure/mgmt/datashare/operations/_invitations_operations.py

@@ -24,7 +24,7 @@ class InvitationsOperations(object):
     :param config: Configuration of service client.
     :param serializer: An object model serializer.
     :param deserializer: An object model deserializer.
-    :ivar api_version: The api version to use. Constant value: "2018-11-01-preview".
+    :ivar api_version: The api version to use. Constant value: "2019-11-01".
     """
 
     models = models
@@ -34,7 +34,7 @@ def __init__(self, client, config, serializer, deserializer):
         self._client = client
         self._serialize = serializer
         self._deserialize = deserializer
-        self.api_version = "2018-11-01-preview"
+        self.api_version = "2019-11-01"
 
         self.config = config
 

sdk/datashare/azure-mgmt-datashare/azure/mgmt/datashare/operations/_operations.py

@@ -24,7 +24,7 @@ class Operations(object):
     :param config: Configuration of service client.
     :param serializer: An object model serializer.
     :param deserializer: An object model deserializer.
-    :ivar api_version: The api version to use. Constant value: "2018-11-01-preview".
+    :ivar api_version: The api version to use. Constant value: "2019-11-01".
     """
 
     models = models
@@ -34,7 +34,7 @@ def __init__(self, client, config, serializer, deserializer):
         self._client = client
         self._serialize = serializer
         self._deserialize = deserializer
-        self.api_version = "2018-11-01-preview"
+        self.api_version = "2019-11-01"
 
         self.config = config