[ReleasePR azure-mgmt-kusto] Add a new kusto version with changes

sdk/kusto/azure-mgmt-kusto/azure/mgmt/kusto/_kusto_management_client.py

@@ -61,7 +61,7 @@ def __init__(
         super(KustoManagementClient, 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 = '2019-11-09'
+        self.api_version = '2020-02-15'
         self._serialize = Serializer(client_models)
         self._deserialize = Deserializer(client_models)
 

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

@@ -42,6 +42,8 @@
     from ._models_py3 import IdentityUserAssignedIdentitiesValue
     from ._models_py3 import IotHubDataConnection
     from ._models_py3 import KeyVaultProperties
+    from ._models_py3 import LanguageExtension
+    from ._models_py3 import LanguageExtensionsList
     from ._models_py3 import Operation
     from ._models_py3 import OperationDisplay
     from ._models_py3 import OptimizedAutoscale
@@ -87,6 +89,8 @@
     from ._models import IdentityUserAssignedIdentitiesValue
     from ._models import IotHubDataConnection
     from ._models import KeyVaultProperties
+    from ._models import LanguageExtension
+    from ._models import LanguageExtensionsList
     from ._models import Operation
     from ._models import OperationDisplay
     from ._models import OptimizedAutoscale
@@ -108,11 +112,13 @@
 from ._paged_models import DatabasePrincipalPaged
 from ._paged_models import DataConnectionPaged
 from ._paged_models import FollowerDatabaseDefinitionPaged
+from ._paged_models import LanguageExtensionPaged
 from ._paged_models import OperationPaged
 from ._paged_models import SkuDescriptionPaged
 from ._kusto_management_client_enums import (
     State,
     ProvisioningState,
+    LanguageExtensionName,
     AzureSkuName,
     AzureSkuTier,
     AzureScaleType,
@@ -164,6 +170,8 @@
     'IdentityUserAssignedIdentitiesValue',
     'IotHubDataConnection',
     'KeyVaultProperties',
+    'LanguageExtension',
+    'LanguageExtensionsList',
     'Operation',
     'OperationDisplay',
     'OptimizedAutoscale',
@@ -180,6 +188,7 @@
     'ClusterPaged',
     'SkuDescriptionPaged',
     'AzureResourceSkuPaged',
+    'LanguageExtensionPaged',
     'ClusterPrincipalAssignmentPaged',
     'DatabasePaged',
     'DatabasePrincipalPaged',
@@ -189,6 +198,7 @@
     'OperationPaged',
     'State',
     'ProvisioningState',
+    'LanguageExtensionName',
     'AzureSkuName',
     'AzureSkuTier',
     'AzureScaleType',

sdk/kusto/azure-mgmt-kusto/azure/mgmt/kusto/models/_kusto_management_client_enums.py

@@ -35,6 +35,12 @@ class ProvisioningState(str, Enum):
     moving = "Moving"
 
 
+class LanguageExtensionName(str, Enum):
+
+    python = "PYTHON"
+    r = "R"
+
+
 class AzureSkuName(str, Enum):
 
     standard_ds13_v21_tb_ps = "Standard_DS13_v2+1TB_PS"
@@ -49,6 +55,15 @@ class AzureSkuName(str, Enum):
     standard_d12_v2 = "Standard_D12_v2"
     standard_l4s = "Standard_L4s"
     dev_no_sla_standard_d11_v2 = "Dev(No SLA)_Standard_D11_v2"
+    standard_e2a_v4 = "Standard_E2a_v4"
+    standard_e4a_v4 = "Standard_E4a_v4"
+    standard_e8a_v4 = "Standard_E8a_v4"
+    standard_e16a_v4 = "Standard_E16a_v4"
+    standard_e8as_v41_tb_ps = "Standard_E8as_v4+1TB_PS"
+    standard_e8as_v42_tb_ps = "Standard_E8as_v4+2TB_PS"
+    standard_e16as_v43_tb_ps = "Standard_E16as_v4+3TB_PS"
+    standard_e16as_v44_tb_ps = "Standard_E16as_v4+4TB_PS"
+    dev_no_sla_standard_e2a_v4 = "Dev(No SLA)_Standard_E2a_v4"
 
 
 class AzureSkuTier(str, Enum):

sdk/kusto/azure-mgmt-kusto/azure/mgmt/kusto/models/_models.py

@@ -263,7 +263,11 @@ class AzureSku(Model):
      'Standard_DS13_v2+1TB_PS', 'Standard_DS13_v2+2TB_PS',
      'Standard_DS14_v2+3TB_PS', 'Standard_DS14_v2+4TB_PS', 'Standard_D13_v2',
      'Standard_D14_v2', 'Standard_L8s', 'Standard_L16s', 'Standard_D11_v2',
-     'Standard_D12_v2', 'Standard_L4s', 'Dev(No SLA)_Standard_D11_v2'
+     'Standard_D12_v2', 'Standard_L4s', 'Dev(No SLA)_Standard_D11_v2',
+     'Standard_E2a_v4', 'Standard_E4a_v4', 'Standard_E8a_v4',
+     'Standard_E16a_v4', 'Standard_E8as_v4+1TB_PS', 'Standard_E8as_v4+2TB_PS',
+     'Standard_E16as_v4+3TB_PS', 'Standard_E16as_v4+4TB_PS', 'Dev(No
+     SLA)_Standard_E2a_v4'
     :type name: str or ~azure.mgmt.kusto.models.AzureSkuName
     :param capacity: The number of instances of the cluster.
     :type capacity: int
@@ -511,6 +515,11 @@ class Cluster(TrackedResource):
     :param key_vault_properties: KeyVault properties for the cluster
      encryption.
     :type key_vault_properties: ~azure.mgmt.kusto.models.KeyVaultProperties
+    :param enable_purge: A boolean value that indicates if the purge
+     operations are enabled. Default value: False .
+    :type enable_purge: bool
+    :param language_extensions: List of the cluster's language extensions.
+    :type language_extensions: ~azure.mgmt.kusto.models.LanguageExtensionsList
     """
 
     _validation = {
@@ -546,6 +555,8 @@ class Cluster(TrackedResource):
         'enable_streaming_ingest': {'key': 'properties.enableStreamingIngest', 'type': 'bool'},
         'virtual_network_configuration': {'key': 'properties.virtualNetworkConfiguration', 'type': 'VirtualNetworkConfiguration'},
         'key_vault_properties': {'key': 'properties.keyVaultProperties', 'type': 'KeyVaultProperties'},
+        'enable_purge': {'key': 'properties.enablePurge', 'type': 'bool'},
+        'language_extensions': {'key': 'properties.languageExtensions', 'type': 'LanguageExtensionsList'},
     }
 
     def __init__(self, **kwargs):
@@ -564,6 +575,8 @@ def __init__(self, **kwargs):
         self.enable_streaming_ingest = kwargs.get('enable_streaming_ingest', False)
         self.virtual_network_configuration = kwargs.get('virtual_network_configuration', None)
         self.key_vault_properties = kwargs.get('key_vault_properties', None)
+        self.enable_purge = kwargs.get('enable_purge', False)
+        self.language_extensions = kwargs.get('language_extensions', None)
 
 
 class ClusterCheckNameRequest(Model):
@@ -759,6 +772,11 @@ class ClusterUpdate(Resource):
     :param key_vault_properties: KeyVault properties for the cluster
      encryption.
     :type key_vault_properties: ~azure.mgmt.kusto.models.KeyVaultProperties
+    :param enable_purge: A boolean value that indicates if the purge
+     operations are enabled. Default value: False .
+    :type enable_purge: bool
+    :param language_extensions: List of the cluster's language extensions.
+    :type language_extensions: ~azure.mgmt.kusto.models.LanguageExtensionsList
     """
 
     _validation = {
@@ -791,6 +809,8 @@ class ClusterUpdate(Resource):
         'enable_streaming_ingest': {'key': 'properties.enableStreamingIngest', 'type': 'bool'},
         'virtual_network_configuration': {'key': 'properties.virtualNetworkConfiguration', 'type': 'VirtualNetworkConfiguration'},
         'key_vault_properties': {'key': 'properties.keyVaultProperties', 'type': 'KeyVaultProperties'},
+        'enable_purge': {'key': 'properties.enablePurge', 'type': 'bool'},
+        'language_extensions': {'key': 'properties.languageExtensions', 'type': 'LanguageExtensionsList'},
     }
 
     def __init__(self, **kwargs):
@@ -810,6 +830,8 @@ def __init__(self, **kwargs):
         self.enable_streaming_ingest = kwargs.get('enable_streaming_ingest', False)
         self.virtual_network_configuration = kwargs.get('virtual_network_configuration', None)
         self.key_vault_properties = kwargs.get('key_vault_properties', None)
+        self.enable_purge = kwargs.get('enable_purge', False)
+        self.language_extensions = kwargs.get('language_extensions', None)
 
 
 class Database(ProxyResource):
@@ -1607,6 +1629,40 @@ def __init__(self, **kwargs):
         self.key_vault_uri = kwargs.get('key_vault_uri', None)
 
 
+class LanguageExtension(Model):
+    """The language extension object.
+
+    :param language_extension_name: The language extension name. Possible
+     values include: 'PYTHON', 'R'
+    :type language_extension_name: str or
+     ~azure.mgmt.kusto.models.LanguageExtensionName
+    """
+
+    _attribute_map = {
+        'language_extension_name': {'key': 'languageExtensionName', 'type': 'str'},
+    }
+
+    def __init__(self, **kwargs):
+        super(LanguageExtension, self).__init__(**kwargs)
+        self.language_extension_name = kwargs.get('language_extension_name', None)
+
+
+class LanguageExtensionsList(Model):
+    """The list of language extension objects.
+
+    :param value: The list of language extensions.
+    :type value: list[~azure.mgmt.kusto.models.LanguageExtension]
+    """
+
+    _attribute_map = {
+        'value': {'key': 'value', 'type': '[LanguageExtension]'},
+    }
+
+    def __init__(self, **kwargs):
+        super(LanguageExtensionsList, self).__init__(**kwargs)
+        self.value = kwargs.get('value', None)
+
+
 class Operation(Model):
     """A REST API operation.
 

sdk/kusto/azure-mgmt-kusto/azure/mgmt/kusto/models/_models_py3.py

@@ -263,7 +263,11 @@ class AzureSku(Model):
      'Standard_DS13_v2+1TB_PS', 'Standard_DS13_v2+2TB_PS',
      'Standard_DS14_v2+3TB_PS', 'Standard_DS14_v2+4TB_PS', 'Standard_D13_v2',
      'Standard_D14_v2', 'Standard_L8s', 'Standard_L16s', 'Standard_D11_v2',
-     'Standard_D12_v2', 'Standard_L4s', 'Dev(No SLA)_Standard_D11_v2'
+     'Standard_D12_v2', 'Standard_L4s', 'Dev(No SLA)_Standard_D11_v2',
+     'Standard_E2a_v4', 'Standard_E4a_v4', 'Standard_E8a_v4',
+     'Standard_E16a_v4', 'Standard_E8as_v4+1TB_PS', 'Standard_E8as_v4+2TB_PS',
+     'Standard_E16as_v4+3TB_PS', 'Standard_E16as_v4+4TB_PS', 'Dev(No
+     SLA)_Standard_E2a_v4'
     :type name: str or ~azure.mgmt.kusto.models.AzureSkuName
     :param capacity: The number of instances of the cluster.
     :type capacity: int
@@ -511,6 +515,11 @@ class Cluster(TrackedResource):
     :param key_vault_properties: KeyVault properties for the cluster
      encryption.
     :type key_vault_properties: ~azure.mgmt.kusto.models.KeyVaultProperties
+    :param enable_purge: A boolean value that indicates if the purge
+     operations are enabled. Default value: False .
+    :type enable_purge: bool
+    :param language_extensions: List of the cluster's language extensions.
+    :type language_extensions: ~azure.mgmt.kusto.models.LanguageExtensionsList
     """
 
     _validation = {
@@ -546,9 +555,11 @@ class Cluster(TrackedResource):
         'enable_streaming_ingest': {'key': 'properties.enableStreamingIngest', 'type': 'bool'},
         'virtual_network_configuration': {'key': 'properties.virtualNetworkConfiguration', 'type': 'VirtualNetworkConfiguration'},
         'key_vault_properties': {'key': 'properties.keyVaultProperties', 'type': 'KeyVaultProperties'},
+        'enable_purge': {'key': 'properties.enablePurge', 'type': 'bool'},
+        'language_extensions': {'key': 'properties.languageExtensions', 'type': 'LanguageExtensionsList'},
     }
 
-    def __init__(self, *, location: str, sku, tags=None, zones=None, identity=None, trusted_external_tenants=None, optimized_autoscale=None, enable_disk_encryption: bool=None, enable_streaming_ingest: bool=False, virtual_network_configuration=None, key_vault_properties=None, **kwargs) -> None:
+    def __init__(self, *, location: str, sku, tags=None, zones=None, identity=None, trusted_external_tenants=None, optimized_autoscale=None, enable_disk_encryption: bool=None, enable_streaming_ingest: bool=False, virtual_network_configuration=None, key_vault_properties=None, enable_purge: bool=False, language_extensions=None, **kwargs) -> None:
         super(Cluster, self).__init__(tags=tags, location=location, **kwargs)
         self.sku = sku
         self.zones = zones
@@ -564,6 +575,8 @@ def __init__(self, *, location: str, sku, tags=None, zones=None, identity=None,
         self.enable_streaming_ingest = enable_streaming_ingest
         self.virtual_network_configuration = virtual_network_configuration
         self.key_vault_properties = key_vault_properties
+        self.enable_purge = enable_purge
+        self.language_extensions = language_extensions
 
 
 class ClusterCheckNameRequest(Model):
@@ -759,6 +772,11 @@ class ClusterUpdate(Resource):
     :param key_vault_properties: KeyVault properties for the cluster
      encryption.
     :type key_vault_properties: ~azure.mgmt.kusto.models.KeyVaultProperties
+    :param enable_purge: A boolean value that indicates if the purge
+     operations are enabled. Default value: False .
+    :type enable_purge: bool
+    :param language_extensions: List of the cluster's language extensions.
+    :type language_extensions: ~azure.mgmt.kusto.models.LanguageExtensionsList
     """
 
     _validation = {
@@ -791,9 +809,11 @@ class ClusterUpdate(Resource):
         'enable_streaming_ingest': {'key': 'properties.enableStreamingIngest', 'type': 'bool'},
         'virtual_network_configuration': {'key': 'properties.virtualNetworkConfiguration', 'type': 'VirtualNetworkConfiguration'},
         'key_vault_properties': {'key': 'properties.keyVaultProperties', 'type': 'KeyVaultProperties'},
+        'enable_purge': {'key': 'properties.enablePurge', 'type': 'bool'},
+        'language_extensions': {'key': 'properties.languageExtensions', 'type': 'LanguageExtensionsList'},
     }
 
-    def __init__(self, *, tags=None, location: str=None, sku=None, identity=None, trusted_external_tenants=None, optimized_autoscale=None, enable_disk_encryption: bool=None, enable_streaming_ingest: bool=False, virtual_network_configuration=None, key_vault_properties=None, **kwargs) -> None:
+    def __init__(self, *, tags=None, location: str=None, sku=None, identity=None, trusted_external_tenants=None, optimized_autoscale=None, enable_disk_encryption: bool=None, enable_streaming_ingest: bool=False, virtual_network_configuration=None, key_vault_properties=None, enable_purge: bool=False, language_extensions=None, **kwargs) -> None:
         super(ClusterUpdate, self).__init__(**kwargs)
         self.tags = tags
         self.location = location
@@ -810,6 +830,8 @@ def __init__(self, *, tags=None, location: str=None, sku=None, identity=None, tr
         self.enable_streaming_ingest = enable_streaming_ingest
         self.virtual_network_configuration = virtual_network_configuration
         self.key_vault_properties = key_vault_properties
+        self.enable_purge = enable_purge
+        self.language_extensions = language_extensions
 
 
 class Database(ProxyResource):
@@ -1607,6 +1629,40 @@ def __init__(self, *, key_name: str, key_version: str, key_vault_uri: str, **kwa
         self.key_vault_uri = key_vault_uri
 
 
+class LanguageExtension(Model):
+    """The language extension object.
+
+    :param language_extension_name: The language extension name. Possible
+     values include: 'PYTHON', 'R'
+    :type language_extension_name: str or
+     ~azure.mgmt.kusto.models.LanguageExtensionName
+    """
+
+    _attribute_map = {
+        'language_extension_name': {'key': 'languageExtensionName', 'type': 'str'},
+    }
+
+    def __init__(self, *, language_extension_name=None, **kwargs) -> None:
+        super(LanguageExtension, self).__init__(**kwargs)
+        self.language_extension_name = language_extension_name
+
+
+class LanguageExtensionsList(Model):
+    """The list of language extension objects.
+
+    :param value: The list of language extensions.
+    :type value: list[~azure.mgmt.kusto.models.LanguageExtension]
+    """
+
+    _attribute_map = {
+        'value': {'key': 'value', 'type': '[LanguageExtension]'},
+    }
+
+    def __init__(self, *, value=None, **kwargs) -> None:
+        super(LanguageExtensionsList, self).__init__(**kwargs)
+        self.value = value
+
+
 class Operation(Model):
     """A REST API operation.
 

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

@@ -64,6 +64,19 @@ class AzureResourceSkuPaged(Paged):
     def __init__(self, *args, **kwargs):
 
         super(AzureResourceSkuPaged, self).__init__(*args, **kwargs)
+class LanguageExtensionPaged(Paged):
+    """
+    A paging container for iterating over a list of :class:`LanguageExtension <azure.mgmt.kusto.models.LanguageExtension>` object
+    """
+
+    _attribute_map = {
+        'next_link': {'key': 'nextLink', 'type': 'str'},
+        'current_page': {'key': 'value', 'type': '[LanguageExtension]'}
+    }
+
+    def __init__(self, *args, **kwargs):
+
+        super(LanguageExtensionPaged, self).__init__(*args, **kwargs)
 class ClusterPrincipalAssignmentPaged(Paged):
     """
     A paging container for iterating over a list of :class:`ClusterPrincipalAssignment <azure.mgmt.kusto.models.ClusterPrincipalAssignment>` object

sdk/kusto/azure-mgmt-kusto/azure/mgmt/kusto/operations/_attached_database_configurations_operations.py

@@ -27,7 +27,7 @@ class AttachedDatabaseConfigurationsOperations(object):
     :param config: Configuration of service client.
     :param serializer: An object model serializer.
     :param deserializer: An object model deserializer.
-    :ivar api_version: Client API Version. Constant value: "2019-11-09".
+    :ivar api_version: Client API Version. Constant value: "2020-02-15".
     """
 
     models = models
@@ -37,7 +37,7 @@ def __init__(self, client, config, serializer, deserializer):
         self._client = client
         self._serialize = serializer
         self._deserialize = deserializer
-        self.api_version = "2019-11-09"
+        self.api_version = "2020-02-15"
 
         self.config = config
 

sdk/kusto/azure-mgmt-kusto/azure/mgmt/kusto/operations/_cluster_principal_assignments_operations.py

@@ -27,7 +27,7 @@ class ClusterPrincipalAssignmentsOperations(object):
     :param config: Configuration of service client.
     :param serializer: An object model serializer.
     :param deserializer: An object model deserializer.
-    :ivar api_version: Client API Version. Constant value: "2019-11-09".
+    :ivar api_version: Client API Version. Constant value: "2020-02-15".
     """
 
     models = models
@@ -37,7 +37,7 @@ def __init__(self, client, config, serializer, deserializer):
         self._client = client
         self._serialize = serializer
         self._deserialize = deserializer
-        self.api_version = "2019-11-09"
+        self.api_version = "2020-02-15"
 
         self.config = config