[k8s-extension] Release v1.1.0 with Updated Models for 2022-03-01

src/k8s-extension/HISTORY.rst

@@ -3,6 +3,12 @@
 Release History
 ===============
 
+1.1.0
+++++++++++++++++++
+* Migrate Extensions api-version to 2022-03-01
+* microsoft.azureml.kubernetes: Remove inference private review warning message
+* microsoft.openservicemesh: Enable System-assigned identity
+
 1.0.4
 ++++++++++++++++++
 * microsoft.azureml.kubernetes: Support SSL secret

src/k8s-extension/azext_k8s_extension/custom.py

@@ -5,7 +5,7 @@
 
 # pylint: disable=unused-argument,too-many-locals
 
-from azext_k8s_extension.utils import (
+from .utils import (
     get_cluster_rp_api_version,
     is_dogfood_cluster,
     read_config_settings_file,

src/k8s-extension/azext_k8s_extension/partner_extensions/AzureMLKubernetes.py

@@ -10,7 +10,7 @@
 import copy
 from hashlib import md5
 from typing import Any, Dict, List, Tuple
-from azext_k8s_extension.utils import get_cluster_rp_api_version
+from ..utils import get_cluster_rp_api_version
 
 import azure.mgmt.relay
 import azure.mgmt.relay.models
@@ -339,7 +339,6 @@ def __validate_config(self, configuration_settings, configuration_protected_sett
         enable_inference = str(enable_inference).lower() == 'true'
 
         if enable_inference:
-            logger.warning("The installed AzureML extension for AML inference is experimental and not covered by customer support. Please use with discretion.")
             self.__validate_scoring_fe_settings(configuration_settings, configuration_protected_settings, release_namespace)
             self.__set_up_inference_ssl(configuration_settings, configuration_protected_settings)
         elif not (enable_training or enable_inference):

src/k8s-extension/azext_k8s_extension/partner_extensions/OpenServiceMesh.py

@@ -49,7 +49,7 @@ def Create(self, cmd, client, resource_group_name, cluster_name, name, cluster_t
         ext_scope = Scope(cluster=scope_cluster, namespace=None)
 
         # NOTE-2: Return a valid Extension object, Instance name and flag for Identity
-        create_identity = False
+        create_identity = True
 
         _validate_tested_distro(cmd, resource_group_name, cluster_name, version)
 
@@ -83,7 +83,7 @@ def _validate_tested_distro(cmd, cluster_resource_group_name, cluster_name, exte
     cluster_resource_id = '/subscriptions/{0}/resourceGroups/{1}/providers/Microsoft.Kubernetes' \
         '/connectedClusters/{2}'.format(subscription_id, cluster_resource_group_name, cluster_name)
 
-    resource = resources.get_by_id(cluster_resource_id, '2020-01-01-preview')
+    resource = resources.get_by_id(cluster_resource_id, '2021-10-01')
     cluster_distro = resource.properties['distribution'].lower()
 
     if cluster_distro == "general":

src/k8s-extension/azext_k8s_extension/tests/latest/test_k8s_extension_scenario.py

@@ -15,27 +15,20 @@
 class K8sExtensionScenarioTest(ScenarioTest):
     @record_only()
     def test_k8s_extension(self):
-        resource_type = 'microsoft.openservicemesh'
+        extension_type = 'microsoft.dapr'
         self.kwargs.update({
-            'name': 'openservicemesh',
-            'rg': 'nanthirg1006',
-            'cluster_name': 'nanthiaks1006',
+            'name': 'dapr',
+            'rg': 'azurecli-tests',
+            'cluster_name': 'arc-cluster',
             'cluster_type': 'connectedClusters',
-            'extension_type': resource_type,
-            'release_train': 'pilot',
-            'version': '0.9.2'
+            'extension_type': extension_type,
+            'release_train': 'stable',
+            'version': '1.6.0',
         })
 
         self.cmd('k8s-extension create -g {rg} -n {name} -c {cluster_name} --cluster-type {cluster_type} '
-                 '--extension-type {extension_type} --release-train {release_train} --version {version}',
-                 checks=[
-                     self.check('name', '{name}'),
-                     self.check('releaseTrain', '{release_train}'),
-                     self.check('version', '{version}'),
-                     self.check('resourceGroup', '{rg}'),
-                     self.check('extensionType', '{extension_type}')
-                 ]
-                 )
+                 '--extension-type {extension_type} --release-train {release_train} --version {version} '
+                 '--no-wait')
 
         # Update requires agent running in k8s cluster that is connected to Azure - so no update tests here
         # self.cmd('k8s-extension update -g {rg} -n {name} --tags foo=boo', checks=[
@@ -45,7 +38,7 @@ def test_k8s_extension(self):
         installed_exts = self.cmd('k8s-extension list -c {cluster_name} -g {rg} --cluster-type {cluster_type}').get_output_in_json()
         found_extension = False
         for item in installed_exts:
-            if item['extensionType'] == resource_type:
+            if item['extensionType'] == extension_type:
                 found_extension = True
                 break
         self.assertTrue(found_extension)
@@ -58,12 +51,12 @@ def test_k8s_extension(self):
             self.check('extensionType', '{extension_type}')
         ])
 
-        self.cmd('k8s-extension delete -g {rg} -c {cluster_name} -n {name} --cluster-type {cluster_type} -y')
+        self.cmd('k8s-extension delete -g {rg} -c {cluster_name} -n {name} --cluster-type {cluster_type} --force -y')
 
         installed_exts = self.cmd('k8s-extension list -c {cluster_name} -g {rg} --cluster-type {cluster_type}').get_output_in_json()
         found_extension = False
         for item in installed_exts:
-            if item['extensionType'] == resource_type:
+            if item['extensionType'] == extension_type:
                 found_extension = True
                 break
         self.assertFalse(found_extension)

src/k8s-extension/azext_k8s_extension/utils.py

@@ -6,7 +6,7 @@
 import json
 from typing import Tuple
 from urllib.parse import urlparse
-from azext_k8s_extension import consts
+from . import consts
 from azure.cli.core.azclierror import InvalidArgumentValueError
 
 

src/k8s-extension/azext_k8s_extension/vendored_sdks/__init__.py

@@ -7,9 +7,6 @@
 # --------------------------------------------------------------------------
 
 from ._source_control_configuration_client import SourceControlConfigurationClient
-from ._version import VERSION
-
-__version__ = VERSION
 __all__ = ['SourceControlConfigurationClient']
 
 try:

src/k8s-extension/azext_k8s_extension/vendored_sdks/_configuration.py

@@ -1,16 +1,18 @@
 # 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
 from azure.core.pipeline import policies
-from azure.mgmt.core.policies import ARMHttpLoggingPolicy
+from azure.mgmt.core.policies import ARMChallengeAuthenticationPolicy, ARMHttpLoggingPolicy
 
 from ._version import VERSION
 
@@ -20,7 +22,6 @@
 
     from azure.core.credentials import TokenCredential
 
-
 class SourceControlConfigurationClientConfiguration(Configuration):
     """Configuration for SourceControlConfigurationClient.
 
@@ -48,9 +49,8 @@ def __init__(
 
         self.credential = credential
         self.subscription_id = subscription_id
-        self.api_version = "2021-09-01"
         self.credential_scopes = kwargs.pop('credential_scopes', ['https://management.azure.com/.default'])
-        kwargs.setdefault('sdk_moniker', 'mgmt-kubernetesconfiguration/{}'.format(VERSION))
+        kwargs.setdefault('sdk_moniker', 'azure-mgmt-kubernetesconfiguration/{}'.format(VERSION))
         self._configure(**kwargs)
 
     def _configure(
@@ -68,4 +68,4 @@ def _configure(
         self.redirect_policy = kwargs.get('redirect_policy') or policies.RedirectPolicy(**kwargs)
         self.authentication_policy = kwargs.get('authentication_policy')
         if self.credential and not self.authentication_policy:
-            self.authentication_policy = policies.BearerTokenCredentialPolicy(self.credential, *self.credential_scopes, **kwargs)
+            self.authentication_policy = ARMChallengeAuthenticationPolicy(self.credential, *self.credential_scopes, **kwargs)