[T1]kusto

sdk/kusto/azure-mgmt-kusto/CHANGELOG.md

@@ -1,5 +1,16 @@
 # Release History
 
+## 0.10.0 (2020-10-23)
+
+**Features**
+
+  - Model EventHubDataConnection has a new parameter provisioning_state
+  - Model KeyVaultProperties has a new parameter user_identity
+  - Model EventGridDataConnection has a new parameter provisioning_state
+  - Model IotHubDataConnection has a new parameter provisioning_state
+  - Model Cluster has a new parameter engine_type
+  - Model ClusterUpdate has a new parameter engine_type
+
 ## 0.9.0 (2020-07-13)
 
 **Features**

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 = '2020-06-14'
+        self.api_version = '2020-09-18'
         self._serialize = Serializer(client_models)
         self._deserialize = Deserializer(client_models)
 

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

@@ -119,6 +119,7 @@
     State,
     ProvisioningState,
     LanguageExtensionName,
+    EngineType,
     AzureSkuName,
     AzureSkuTier,
     AzureScaleType,
@@ -200,6 +201,7 @@
     'State',
     'ProvisioningState',
     'LanguageExtensionName',
+    'EngineType',
     'AzureSkuName',
     'AzureSkuTier',
     'AzureScaleType',

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

@@ -41,6 +41,12 @@ class LanguageExtensionName(str, Enum):
     r = "R"
 
 
+class EngineType(str, Enum):
+
+    v2 = "V2"
+    v3 = "V3"
+
+
 class AzureSkuName(str, Enum):
 
     standard_ds13_v21_tb_ps = "Standard_DS13_v2+1TB_PS"
@@ -55,6 +61,7 @@ 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_e64i_v3 = "Standard_E64i_v3"
     standard_e2a_v4 = "Standard_E2a_v4"
     standard_e4a_v4 = "Standard_E4a_v4"
     standard_e8a_v4 = "Standard_E8a_v4"
@@ -169,6 +176,8 @@ class IdentityType(str, Enum):
 
     none = "None"
     system_assigned = "SystemAssigned"
+    user_assigned = "UserAssigned"
+    system_assigned_user_assigned = "SystemAssigned, UserAssigned"
 
 
 class DatabasePrincipalRole(str, Enum):

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

@@ -264,10 +264,10 @@ class AzureSku(Model):
      '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_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'
+     'Standard_E64i_v3', '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
@@ -524,6 +524,8 @@ class Cluster(TrackedResource):
     :param enable_double_encryption: A boolean value that indicates if double
      encryption is enabled. Default value: False .
     :type enable_double_encryption: bool
+    :param engine_type: The engine type. Possible values include: 'V2', 'V3'
+    :type engine_type: str or ~azure.mgmt.kusto.models.EngineType
     """
 
     _validation = {
@@ -563,6 +565,7 @@ class Cluster(TrackedResource):
         'enable_purge': {'key': 'properties.enablePurge', 'type': 'bool'},
         'language_extensions': {'key': 'properties.languageExtensions', 'type': 'LanguageExtensionsList'},
         'enable_double_encryption': {'key': 'properties.enableDoubleEncryption', 'type': 'bool'},
+        'engine_type': {'key': 'properties.engineType', 'type': 'str'},
     }
 
     def __init__(self, **kwargs):
@@ -584,6 +587,7 @@ def __init__(self, **kwargs):
         self.enable_purge = kwargs.get('enable_purge', False)
         self.language_extensions = None
         self.enable_double_encryption = kwargs.get('enable_double_encryption', False)
+        self.engine_type = kwargs.get('engine_type', None)
 
 
 class ClusterCheckNameRequest(Model):
@@ -788,6 +792,8 @@ class ClusterUpdate(Resource):
     :param enable_double_encryption: A boolean value that indicates if double
      encryption is enabled. Default value: False .
     :type enable_double_encryption: bool
+    :param engine_type: The engine type. Possible values include: 'V2', 'V3'
+    :type engine_type: str or ~azure.mgmt.kusto.models.EngineType
     """
 
     _validation = {
@@ -824,6 +830,7 @@ class ClusterUpdate(Resource):
         'enable_purge': {'key': 'properties.enablePurge', 'type': 'bool'},
         'language_extensions': {'key': 'properties.languageExtensions', 'type': 'LanguageExtensionsList'},
         'enable_double_encryption': {'key': 'properties.enableDoubleEncryption', 'type': 'bool'},
+        'engine_type': {'key': 'properties.engineType', 'type': 'str'},
     }
 
     def __init__(self, **kwargs):
@@ -846,6 +853,7 @@ def __init__(self, **kwargs):
         self.enable_purge = kwargs.get('enable_purge', False)
         self.language_extensions = None
         self.enable_double_encryption = kwargs.get('enable_double_encryption', False)
+        self.engine_type = kwargs.get('engine_type', None)
 
 
 class Database(ProxyResource):
@@ -1311,6 +1319,11 @@ class EventGridDataConnection(DataConnection):
      'Microsoft.Storage.BlobRenamed'
     :type blob_storage_event_type: str or
      ~azure.mgmt.kusto.models.BlobStorageEventType
+    :ivar provisioning_state: The provisioned state of the resource. Possible
+     values include: 'Running', 'Creating', 'Deleting', 'Succeeded', 'Failed',
+     'Moving'
+    :vartype provisioning_state: str or
+     ~azure.mgmt.kusto.models.ProvisioningState
     """
 
     _validation = {
@@ -1321,6 +1334,7 @@ class EventGridDataConnection(DataConnection):
         'storage_account_resource_id': {'required': True},
         'event_hub_resource_id': {'required': True},
         'consumer_group': {'required': True},
+        'provisioning_state': {'readonly': True},
     }
 
     _attribute_map = {
@@ -1337,6 +1351,7 @@ class EventGridDataConnection(DataConnection):
         'data_format': {'key': 'properties.dataFormat', 'type': 'str'},
         'ignore_first_record': {'key': 'properties.ignoreFirstRecord', 'type': 'bool'},
         'blob_storage_event_type': {'key': 'properties.blobStorageEventType', 'type': 'str'},
+        'provisioning_state': {'key': 'properties.provisioningState', 'type': 'str'},
     }
 
     def __init__(self, **kwargs):
@@ -1349,6 +1364,7 @@ def __init__(self, **kwargs):
         self.data_format = kwargs.get('data_format', None)
         self.ignore_first_record = kwargs.get('ignore_first_record', None)
         self.blob_storage_event_type = kwargs.get('blob_storage_event_type', None)
+        self.provisioning_state = None
         self.kind = 'EventGrid'
 
 
@@ -1393,6 +1409,11 @@ class EventHubDataConnection(DataConnection):
     :param compression: The event hub messages compression type. Possible
      values include: 'None', 'GZip'
     :type compression: str or ~azure.mgmt.kusto.models.Compression
+    :ivar provisioning_state: The provisioned state of the resource. Possible
+     values include: 'Running', 'Creating', 'Deleting', 'Succeeded', 'Failed',
+     'Moving'
+    :vartype provisioning_state: str or
+     ~azure.mgmt.kusto.models.ProvisioningState
     """
 
     _validation = {
@@ -1402,6 +1423,7 @@ class EventHubDataConnection(DataConnection):
         'kind': {'required': True},
         'event_hub_resource_id': {'required': True},
         'consumer_group': {'required': True},
+        'provisioning_state': {'readonly': True},
     }
 
     _attribute_map = {
@@ -1417,6 +1439,7 @@ class EventHubDataConnection(DataConnection):
         'data_format': {'key': 'properties.dataFormat', 'type': 'str'},
         'event_system_properties': {'key': 'properties.eventSystemProperties', 'type': '[str]'},
         'compression': {'key': 'properties.compression', 'type': 'str'},
+        'provisioning_state': {'key': 'properties.provisioningState', 'type': 'str'},
     }
 
     def __init__(self, **kwargs):
@@ -1428,6 +1451,7 @@ def __init__(self, **kwargs):
         self.data_format = kwargs.get('data_format', None)
         self.event_system_properties = kwargs.get('event_system_properties', None)
         self.compression = kwargs.get('compression', None)
+        self.provisioning_state = None
         self.kind = 'EventHub'
 
 
@@ -1481,8 +1505,11 @@ class Identity(Model):
     :vartype principal_id: str
     :ivar tenant_id: The tenant ID of resource.
     :vartype tenant_id: str
-    :param type: Required. The identity type. Possible values include: 'None',
-     'SystemAssigned'
+    :param type: Required. The type of managed identity used. The type
+     'SystemAssigned, UserAssigned' includes both an implicitly created
+     identity and a set of user-assigned identities. The type 'None' will
+     remove all identities. Possible values include: 'None', 'SystemAssigned',
+     'UserAssigned', 'SystemAssigned, UserAssigned'
     :type type: str or ~azure.mgmt.kusto.models.IdentityType
     :param user_assigned_identities: The list of user identities associated
      with the Kusto cluster. The user identity dictionary key references will
@@ -1501,7 +1528,7 @@ class Identity(Model):
     _attribute_map = {
         'principal_id': {'key': 'principalId', 'type': 'str'},
         'tenant_id': {'key': 'tenantId', 'type': 'str'},
-        'type': {'key': 'type', 'type': 'IdentityType'},
+        'type': {'key': 'type', 'type': 'str'},
         'user_assigned_identities': {'key': 'userAssignedIdentities', 'type': '{IdentityUserAssignedIdentitiesValue}'},
     }
 
@@ -1582,6 +1609,11 @@ class IotHubDataConnection(DataConnection):
     :param shared_access_policy_name: Required. The name of the share access
      policy
     :type shared_access_policy_name: str
+    :ivar provisioning_state: The provisioned state of the resource. Possible
+     values include: 'Running', 'Creating', 'Deleting', 'Succeeded', 'Failed',
+     'Moving'
+    :vartype provisioning_state: str or
+     ~azure.mgmt.kusto.models.ProvisioningState
     """
 
     _validation = {
@@ -1592,6 +1624,7 @@ class IotHubDataConnection(DataConnection):
         'iot_hub_resource_id': {'required': True},
         'consumer_group': {'required': True},
         'shared_access_policy_name': {'required': True},
+        'provisioning_state': {'readonly': True},
     }
 
     _attribute_map = {
@@ -1607,6 +1640,7 @@ class IotHubDataConnection(DataConnection):
         'data_format': {'key': 'properties.dataFormat', 'type': 'str'},
         'event_system_properties': {'key': 'properties.eventSystemProperties', 'type': '[str]'},
         'shared_access_policy_name': {'key': 'properties.sharedAccessPolicyName', 'type': 'str'},
+        'provisioning_state': {'key': 'properties.provisioningState', 'type': 'str'},
     }
 
     def __init__(self, **kwargs):
@@ -1618,6 +1652,7 @@ def __init__(self, **kwargs):
         self.data_format = kwargs.get('data_format', None)
         self.event_system_properties = kwargs.get('event_system_properties', None)
         self.shared_access_policy_name = kwargs.get('shared_access_policy_name', None)
+        self.provisioning_state = None
         self.kind = 'IotHub'
 
 
@@ -1628,29 +1663,33 @@ class KeyVaultProperties(Model):
 
     :param key_name: Required. The name of the key vault key.
     :type key_name: str
-    :param key_version: Required. The version of the key vault key.
+    :param key_version: The version of the key vault key.
     :type key_version: str
     :param key_vault_uri: Required. The Uri of the key vault.
     :type key_vault_uri: str
+    :param user_identity: The user assigned identity (ARM resource id) that
+     has access to the key.
+    :type user_identity: str
     """
 
     _validation = {
         'key_name': {'required': True},
-        'key_version': {'required': True},
         'key_vault_uri': {'required': True},
     }
 
     _attribute_map = {
         'key_name': {'key': 'keyName', 'type': 'str'},
         'key_version': {'key': 'keyVersion', 'type': 'str'},
         'key_vault_uri': {'key': 'keyVaultUri', 'type': 'str'},
+        'user_identity': {'key': 'userIdentity', 'type': 'str'},
     }
 
     def __init__(self, **kwargs):
         super(KeyVaultProperties, self).__init__(**kwargs)
         self.key_name = kwargs.get('key_name', None)
         self.key_version = kwargs.get('key_version', None)
         self.key_vault_uri = kwargs.get('key_vault_uri', None)
+        self.user_identity = kwargs.get('user_identity', None)
 
 
 class LanguageExtension(Model):