def METHOD_NAME(cli_ctx, *_):
    from azext_connectedk8s.vendored_sdks.preview_2022_10_01 import ConnectedKubernetesClient
    if os.getenv('AZURE_ACCESS_TOKEN'):
        validate_custom_token()
        credential = AccessTokenCredential(access_token=os.getenv('AZURE_ACCESS_TOKEN'))
        return get_mgmt_service_client(cli_ctx, ConnectedKubernetesClient, subscription_id=os.getenv('AZURE_SUBSCRIPTION_ID'), credential=credential)
    return get_mgmt_service_client(cli_ctx, ConnectedKubernetesClient)