From f0cca1430953a51c2ed7569e6c6a5fe89bf469ea Mon Sep 17 00:00:00 2001 From: SDKAuto Date: Tue, 6 Dec 2022 00:49:14 +0000 Subject: [PATCH] CodeGen from PR 21765 in Azure/azure-rest-api-specs Merge 64afba8eef1cc3b7e3ffa1b64d66d7d669983f5c into 675f5a321159c28656edd4b2ee5fd5de2b0ef40d --- .../azure-mgmt-databricks/_meta.json | 4 +- .../_azure_databricks_management_client.py | 13 +- .../azure/mgmt/databricks/_configuration.py | 12 -- .../azure/mgmt/databricks/_version.py | 2 +- .../_azure_databricks_management_client.py | 13 +- .../mgmt/databricks/aio/_configuration.py | 12 -- .../databricks/aio/operations/__init__.py | 4 +- .../_access_connectors_operations.py | 63 +++---- .../databricks/aio/operations/_operations.py | 16 +- ...twork_dependencies_endpoints_operations.py | 2 +- ...private_endpoint_connections_operations.py | 26 +-- .../_private_link_resources_operations.py | 18 +- .../operations/_vnet_peering_operations.py | 26 +-- .../aio/operations/_workspaces_operations.py | 45 ++--- .../azure/mgmt/databricks/models/__init__.py | 10 +- ...zure_databricks_management_client_enums.py | 18 +- .../mgmt/databricks/models/_models_py3.py | 163 ++++++++++++------ .../mgmt/databricks/operations/__init__.py | 4 +- .../_access_connectors_operations.py | 87 ++++------ .../mgmt/databricks/operations/_operations.py | 16 +- ...twork_dependencies_endpoints_operations.py | 2 +- ...private_endpoint_connections_operations.py | 26 +-- .../_private_link_resources_operations.py | 18 +- .../operations/_vnet_peering_operations.py | 26 +-- .../operations/_workspaces_operations.py | 45 ++--- .../access_connector_create_or_update.py | 2 +- ...tor_create_or_update_with_user_assigned.py | 42 +++++ .../access_connector_delete.py | 2 +- .../generated_samples/access_connector_get.py | 2 +- .../access_connector_patch_update.py | 2 +- ...ccess_connectors_list_by_resource_group.py | 2 +- ...cess_connectors_list_by_subscription_id.py | 2 +- 32 files changed, 309 insertions(+), 416 deletions(-) create mode 100644 sdk/databricks/azure-mgmt-databricks/generated_samples/access_connector_create_or_update_with_user_assigned.py diff --git a/sdk/databricks/azure-mgmt-databricks/_meta.json b/sdk/databricks/azure-mgmt-databricks/_meta.json index 0646bb60ab17..ad2062a720b5 100644 --- a/sdk/databricks/azure-mgmt-databricks/_meta.json +++ b/sdk/databricks/azure-mgmt-databricks/_meta.json @@ -1,11 +1,11 @@ { - "commit": "171bef6183260f0ae968086596495813fcd29c4e", + "commit": "74abc2bdcf26359e02418b1fe391471627228e33", "repository_url": "https://github.com/Azure/azure-rest-api-specs", "autorest": "3.9.2", "use": [ "@autorest/python@6.2.7", "@autorest/modelerfour@4.24.3" ], - "autorest_command": "autorest specification/databricks/resource-manager/readme.md --generate-sample=True --include-x-ms-examples-original-file=True --python --python-sdks-folder=/home/vsts/work/1/azure-sdk-for-python/sdk --use=@autorest/python@6.2.7 --use=@autorest/modelerfour@4.24.3 --version=3.9.2 --version-tolerant=False", + "autorest_command": "autorest specification/databricks/resource-manager/readme.md --generate-sample=True --include-x-ms-examples-original-file=True --python --python-sdks-folder=/mnt/vss/_work/1/s/azure-sdk-for-python/sdk --use=@autorest/python@6.2.7 --use=@autorest/modelerfour@4.24.3 --version=3.9.2 --version-tolerant=False", "readme": "specification/databricks/resource-manager/readme.md" } \ No newline at end of file diff --git a/sdk/databricks/azure-mgmt-databricks/azure/mgmt/databricks/_azure_databricks_management_client.py b/sdk/databricks/azure-mgmt-databricks/azure/mgmt/databricks/_azure_databricks_management_client.py index f5485cf5783f..51c97b2e92b5 100644 --- a/sdk/databricks/azure-mgmt-databricks/azure/mgmt/databricks/_azure_databricks_management_client.py +++ b/sdk/databricks/azure-mgmt-databricks/azure/mgmt/databricks/_azure_databricks_management_client.py @@ -34,6 +34,8 @@ class AzureDatabricksManagementClient: # pylint: disable=client-accepts-api-ver """The Microsoft Azure management APIs allow end users to operate on Azure Databricks Workspace resources. + :ivar access_connectors: AccessConnectorsOperations operations + :vartype access_connectors: azure.mgmt.databricks.operations.AccessConnectorsOperations :ivar workspaces: WorkspacesOperations operations :vartype workspaces: azure.mgmt.databricks.operations.WorkspacesOperations :ivar operations: Operations operations @@ -50,17 +52,12 @@ class AzureDatabricksManagementClient: # pylint: disable=client-accepts-api-ver azure.mgmt.databricks.operations.OutboundNetworkDependenciesEndpointsOperations :ivar vnet_peering: VNetPeeringOperations operations :vartype vnet_peering: azure.mgmt.databricks.operations.VNetPeeringOperations - :ivar access_connectors: AccessConnectorsOperations operations - :vartype access_connectors: azure.mgmt.databricks.operations.AccessConnectorsOperations :param credential: Credential needed for the client to connect to Azure. Required. :type credential: ~azure.core.credentials.TokenCredential :param subscription_id: The ID of the target subscription. Required. :type subscription_id: str :param base_url: Service URL. Default value is "https://management.azure.com". :type base_url: str - :keyword api_version: Api Version. Default value is "2022-04-01-preview". Note that overriding - this default value may result in unsupported behavior. - :paramtype api_version: str :keyword int polling_interval: Default waiting time between two polls for LRO operations if no Retry-After header is present. """ @@ -81,6 +78,9 @@ def __init__( self._serialize = Serializer(client_models) self._deserialize = Deserializer(client_models) self._serialize.client_side_validation = False + self.access_connectors = AccessConnectorsOperations( + self._client, self._config, self._serialize, self._deserialize + ) self.workspaces = WorkspacesOperations(self._client, self._config, self._serialize, self._deserialize) self.operations = Operations(self._client, self._config, self._serialize, self._deserialize) self.private_link_resources = PrivateLinkResourcesOperations( @@ -93,9 +93,6 @@ def __init__( self._client, self._config, self._serialize, self._deserialize ) self.vnet_peering = VNetPeeringOperations(self._client, self._config, self._serialize, self._deserialize) - self.access_connectors = AccessConnectorsOperations( - self._client, self._config, self._serialize, self._deserialize - ) def _send_request(self, request: HttpRequest, **kwargs: Any) -> HttpResponse: """Runs the network request through the client's chained policies. diff --git a/sdk/databricks/azure-mgmt-databricks/azure/mgmt/databricks/_configuration.py b/sdk/databricks/azure-mgmt-databricks/azure/mgmt/databricks/_configuration.py index ffa9b4da635e..3b9c2e63367e 100644 --- a/sdk/databricks/azure-mgmt-databricks/azure/mgmt/databricks/_configuration.py +++ b/sdk/databricks/azure-mgmt-databricks/azure/mgmt/databricks/_configuration.py @@ -6,7 +6,6 @@ # Changes may cause incorrect behavior and will be lost if the code is regenerated. # -------------------------------------------------------------------------- -import sys from typing import Any, TYPE_CHECKING from azure.core.configuration import Configuration @@ -15,11 +14,6 @@ from ._version import VERSION -if sys.version_info >= (3, 8): - from typing import Literal # pylint: disable=no-name-in-module, ungrouped-imports -else: - from typing_extensions import Literal # type: ignore # pylint: disable=ungrouped-imports - if TYPE_CHECKING: # pylint: disable=unused-import,ungrouped-imports from azure.core.credentials import TokenCredential @@ -35,15 +29,10 @@ class AzureDatabricksManagementClientConfiguration(Configuration): # pylint: di :type credential: ~azure.core.credentials.TokenCredential :param subscription_id: The ID of the target subscription. Required. :type subscription_id: str - :keyword api_version: Api Version. Default value is "2022-04-01-preview". Note that overriding - this default value may result in unsupported behavior. - :paramtype api_version: str """ def __init__(self, credential: "TokenCredential", subscription_id: str, **kwargs: Any) -> None: super(AzureDatabricksManagementClientConfiguration, self).__init__(**kwargs) - api_version: Literal["2022-04-01-preview"] = kwargs.pop("api_version", "2022-04-01-preview") - if credential is None: raise ValueError("Parameter 'credential' must not be None.") if subscription_id is None: @@ -51,7 +40,6 @@ def __init__(self, credential: "TokenCredential", subscription_id: str, **kwargs self.credential = credential self.subscription_id = subscription_id - self.api_version = api_version self.credential_scopes = kwargs.pop("credential_scopes", ["https://management.azure.com/.default"]) kwargs.setdefault("sdk_moniker", "mgmt-databricks/{}".format(VERSION)) self._configure(**kwargs) diff --git a/sdk/databricks/azure-mgmt-databricks/azure/mgmt/databricks/_version.py b/sdk/databricks/azure-mgmt-databricks/azure/mgmt/databricks/_version.py index f1fb63697cf5..e5754a47ce68 100644 --- a/sdk/databricks/azure-mgmt-databricks/azure/mgmt/databricks/_version.py +++ b/sdk/databricks/azure-mgmt-databricks/azure/mgmt/databricks/_version.py @@ -6,4 +6,4 @@ # Changes may cause incorrect behavior and will be lost if the code is regenerated. # -------------------------------------------------------------------------- -VERSION = "1.1.0b2" +VERSION = "1.0.0b1" diff --git a/sdk/databricks/azure-mgmt-databricks/azure/mgmt/databricks/aio/_azure_databricks_management_client.py b/sdk/databricks/azure-mgmt-databricks/azure/mgmt/databricks/aio/_azure_databricks_management_client.py index e0b9c2b6413a..4a07b135b74d 100644 --- a/sdk/databricks/azure-mgmt-databricks/azure/mgmt/databricks/aio/_azure_databricks_management_client.py +++ b/sdk/databricks/azure-mgmt-databricks/azure/mgmt/databricks/aio/_azure_databricks_management_client.py @@ -34,6 +34,8 @@ class AzureDatabricksManagementClient: # pylint: disable=client-accepts-api-ver """The Microsoft Azure management APIs allow end users to operate on Azure Databricks Workspace resources. + :ivar access_connectors: AccessConnectorsOperations operations + :vartype access_connectors: azure.mgmt.databricks.aio.operations.AccessConnectorsOperations :ivar workspaces: WorkspacesOperations operations :vartype workspaces: azure.mgmt.databricks.aio.operations.WorkspacesOperations :ivar operations: Operations operations @@ -50,17 +52,12 @@ class AzureDatabricksManagementClient: # pylint: disable=client-accepts-api-ver azure.mgmt.databricks.aio.operations.OutboundNetworkDependenciesEndpointsOperations :ivar vnet_peering: VNetPeeringOperations operations :vartype vnet_peering: azure.mgmt.databricks.aio.operations.VNetPeeringOperations - :ivar access_connectors: AccessConnectorsOperations operations - :vartype access_connectors: azure.mgmt.databricks.aio.operations.AccessConnectorsOperations :param credential: Credential needed for the client to connect to Azure. Required. :type credential: ~azure.core.credentials_async.AsyncTokenCredential :param subscription_id: The ID of the target subscription. Required. :type subscription_id: str :param base_url: Service URL. Default value is "https://management.azure.com". :type base_url: str - :keyword api_version: Api Version. Default value is "2022-04-01-preview". Note that overriding - this default value may result in unsupported behavior. - :paramtype api_version: str :keyword int polling_interval: Default waiting time between two polls for LRO operations if no Retry-After header is present. """ @@ -81,6 +78,9 @@ def __init__( self._serialize = Serializer(client_models) self._deserialize = Deserializer(client_models) self._serialize.client_side_validation = False + self.access_connectors = AccessConnectorsOperations( + self._client, self._config, self._serialize, self._deserialize + ) self.workspaces = WorkspacesOperations(self._client, self._config, self._serialize, self._deserialize) self.operations = Operations(self._client, self._config, self._serialize, self._deserialize) self.private_link_resources = PrivateLinkResourcesOperations( @@ -93,9 +93,6 @@ def __init__( self._client, self._config, self._serialize, self._deserialize ) self.vnet_peering = VNetPeeringOperations(self._client, self._config, self._serialize, self._deserialize) - self.access_connectors = AccessConnectorsOperations( - self._client, self._config, self._serialize, self._deserialize - ) def _send_request(self, request: HttpRequest, **kwargs: Any) -> Awaitable[AsyncHttpResponse]: """Runs the network request through the client's chained policies. diff --git a/sdk/databricks/azure-mgmt-databricks/azure/mgmt/databricks/aio/_configuration.py b/sdk/databricks/azure-mgmt-databricks/azure/mgmt/databricks/aio/_configuration.py index 80c40b3e465d..ba1486eedc60 100644 --- a/sdk/databricks/azure-mgmt-databricks/azure/mgmt/databricks/aio/_configuration.py +++ b/sdk/databricks/azure-mgmt-databricks/azure/mgmt/databricks/aio/_configuration.py @@ -6,7 +6,6 @@ # Changes may cause incorrect behavior and will be lost if the code is regenerated. # -------------------------------------------------------------------------- -import sys from typing import Any, TYPE_CHECKING from azure.core.configuration import Configuration @@ -15,11 +14,6 @@ from .._version import VERSION -if sys.version_info >= (3, 8): - from typing import Literal # pylint: disable=no-name-in-module, ungrouped-imports -else: - from typing_extensions import Literal # type: ignore # pylint: disable=ungrouped-imports - if TYPE_CHECKING: # pylint: disable=unused-import,ungrouped-imports from azure.core.credentials_async import AsyncTokenCredential @@ -35,15 +29,10 @@ class AzureDatabricksManagementClientConfiguration(Configuration): # pylint: di :type credential: ~azure.core.credentials_async.AsyncTokenCredential :param subscription_id: The ID of the target subscription. Required. :type subscription_id: str - :keyword api_version: Api Version. Default value is "2022-04-01-preview". Note that overriding - this default value may result in unsupported behavior. - :paramtype api_version: str """ def __init__(self, credential: "AsyncTokenCredential", subscription_id: str, **kwargs: Any) -> None: super(AzureDatabricksManagementClientConfiguration, self).__init__(**kwargs) - api_version: Literal["2022-04-01-preview"] = kwargs.pop("api_version", "2022-04-01-preview") - if credential is None: raise ValueError("Parameter 'credential' must not be None.") if subscription_id is None: @@ -51,7 +40,6 @@ def __init__(self, credential: "AsyncTokenCredential", subscription_id: str, **k self.credential = credential self.subscription_id = subscription_id - self.api_version = api_version self.credential_scopes = kwargs.pop("credential_scopes", ["https://management.azure.com/.default"]) kwargs.setdefault("sdk_moniker", "mgmt-databricks/{}".format(VERSION)) self._configure(**kwargs) diff --git a/sdk/databricks/azure-mgmt-databricks/azure/mgmt/databricks/aio/operations/__init__.py b/sdk/databricks/azure-mgmt-databricks/azure/mgmt/databricks/aio/operations/__init__.py index fb2a003837b4..6ea78842aacf 100644 --- a/sdk/databricks/azure-mgmt-databricks/azure/mgmt/databricks/aio/operations/__init__.py +++ b/sdk/databricks/azure-mgmt-databricks/azure/mgmt/databricks/aio/operations/__init__.py @@ -6,26 +6,26 @@ # Changes may cause incorrect behavior and will be lost if the code is regenerated. # -------------------------------------------------------------------------- +from ._access_connectors_operations import AccessConnectorsOperations from ._workspaces_operations import WorkspacesOperations from ._operations import Operations from ._private_link_resources_operations import PrivateLinkResourcesOperations from ._private_endpoint_connections_operations import PrivateEndpointConnectionsOperations from ._outbound_network_dependencies_endpoints_operations import OutboundNetworkDependenciesEndpointsOperations from ._vnet_peering_operations import VNetPeeringOperations -from ._access_connectors_operations import AccessConnectorsOperations from ._patch import __all__ as _patch_all from ._patch import * # pylint: disable=unused-wildcard-import from ._patch import patch_sdk as _patch_sdk __all__ = [ + "AccessConnectorsOperations", "WorkspacesOperations", "Operations", "PrivateLinkResourcesOperations", "PrivateEndpointConnectionsOperations", "OutboundNetworkDependenciesEndpointsOperations", "VNetPeeringOperations", - "AccessConnectorsOperations", ] __all__.extend([p for p in _patch_all if p not in __all__]) _patch_sdk() diff --git a/sdk/databricks/azure-mgmt-databricks/azure/mgmt/databricks/aio/operations/_access_connectors_operations.py b/sdk/databricks/azure-mgmt-databricks/azure/mgmt/databricks/aio/operations/_access_connectors_operations.py index 5817befb7142..f389a0b98c4c 100644 --- a/sdk/databricks/azure-mgmt-databricks/azure/mgmt/databricks/aio/operations/_access_connectors_operations.py +++ b/sdk/databricks/azure-mgmt-databricks/azure/mgmt/databricks/aio/operations/_access_connectors_operations.py @@ -8,7 +8,6 @@ # -------------------------------------------------------------------------- import sys from typing import Any, AsyncIterable, Callable, Dict, IO, Optional, TypeVar, Union, cast, overload -import urllib.parse from azure.core.async_paging import AsyncItemPaged, AsyncList from azure.core.exceptions import ( @@ -92,8 +91,8 @@ async def get(self, resource_group_name: str, connector_name: str, **kwargs: Any _headers = kwargs.pop("headers", {}) or {} _params = case_insensitive_dict(kwargs.pop("params", {}) or {}) - api_version: Literal["2022-04-01-preview"] = kwargs.pop( - "api_version", _params.pop("api-version", self._config.api_version) + api_version: Literal["2022-10-01-preview"] = kwargs.pop( + "api_version", _params.pop("api-version", "2022-10-01-preview") ) cls: ClsType[_models.AccessConnector] = kwargs.pop("cls", None) @@ -145,8 +144,8 @@ async def _delete_initial( # pylint: disable=inconsistent-return-statements _headers = kwargs.pop("headers", {}) or {} _params = case_insensitive_dict(kwargs.pop("params", {}) or {}) - api_version: Literal["2022-04-01-preview"] = kwargs.pop( - "api_version", _params.pop("api-version", self._config.api_version) + api_version: Literal["2022-10-01-preview"] = kwargs.pop( + "api_version", _params.pop("api-version", "2022-10-01-preview") ) cls: ClsType[None] = kwargs.pop("cls", None) @@ -204,8 +203,8 @@ async def begin_delete(self, resource_group_name: str, connector_name: str, **kw _headers = kwargs.pop("headers", {}) or {} _params = case_insensitive_dict(kwargs.pop("params", {}) or {}) - api_version: Literal["2022-04-01-preview"] = kwargs.pop( - "api_version", _params.pop("api-version", self._config.api_version) + api_version: Literal["2022-10-01-preview"] = kwargs.pop( + "api_version", _params.pop("api-version", "2022-10-01-preview") ) cls: ClsType[None] = kwargs.pop("cls", None) polling: Union[bool, AsyncPollingMethod] = kwargs.pop("polling", True) @@ -264,8 +263,8 @@ async def _create_or_update_initial( _headers = case_insensitive_dict(kwargs.pop("headers", {}) or {}) _params = case_insensitive_dict(kwargs.pop("params", {}) or {}) - api_version: Literal["2022-04-01-preview"] = kwargs.pop( - "api_version", _params.pop("api-version", self._config.api_version) + api_version: Literal["2022-10-01-preview"] = kwargs.pop( + "api_version", _params.pop("api-version", "2022-10-01-preview") ) content_type: Optional[str] = kwargs.pop("content_type", _headers.pop("Content-Type", None)) cls: ClsType[_models.AccessConnector] = kwargs.pop("cls", None) @@ -430,8 +429,8 @@ async def begin_create_or_update( _headers = case_insensitive_dict(kwargs.pop("headers", {}) or {}) _params = case_insensitive_dict(kwargs.pop("params", {}) or {}) - api_version: Literal["2022-04-01-preview"] = kwargs.pop( - "api_version", _params.pop("api-version", self._config.api_version) + api_version: Literal["2022-10-01-preview"] = kwargs.pop( + "api_version", _params.pop("api-version", "2022-10-01-preview") ) content_type: Optional[str] = kwargs.pop("content_type", _headers.pop("Content-Type", None)) cls: ClsType[_models.AccessConnector] = kwargs.pop("cls", None) @@ -495,8 +494,8 @@ async def _update_initial( _headers = case_insensitive_dict(kwargs.pop("headers", {}) or {}) _params = case_insensitive_dict(kwargs.pop("params", {}) or {}) - api_version: Literal["2022-04-01-preview"] = kwargs.pop( - "api_version", _params.pop("api-version", self._config.api_version) + api_version: Literal["2022-10-01-preview"] = kwargs.pop( + "api_version", _params.pop("api-version", "2022-10-01-preview") ) content_type: Optional[str] = kwargs.pop("content_type", _headers.pop("Content-Type", None)) cls: ClsType[Optional[_models.AccessConnector]] = kwargs.pop("cls", None) @@ -657,8 +656,8 @@ async def begin_update( _headers = case_insensitive_dict(kwargs.pop("headers", {}) or {}) _params = case_insensitive_dict(kwargs.pop("params", {}) or {}) - api_version: Literal["2022-04-01-preview"] = kwargs.pop( - "api_version", _params.pop("api-version", self._config.api_version) + api_version: Literal["2022-10-01-preview"] = kwargs.pop( + "api_version", _params.pop("api-version", "2022-10-01-preview") ) content_type: Optional[str] = kwargs.pop("content_type", _headers.pop("Content-Type", None)) cls: ClsType[_models.AccessConnector] = kwargs.pop("cls", None) @@ -721,8 +720,8 @@ def list_by_resource_group( _headers = kwargs.pop("headers", {}) or {} _params = case_insensitive_dict(kwargs.pop("params", {}) or {}) - api_version: Literal["2022-04-01-preview"] = kwargs.pop( - "api_version", _params.pop("api-version", self._config.api_version) + api_version: Literal["2022-10-01-preview"] = kwargs.pop( + "api_version", _params.pop("api-version", "2022-10-01-preview") ) cls: ClsType[_models.AccessConnectorListResult] = kwargs.pop("cls", None) @@ -749,18 +748,7 @@ def prepare_request(next_link=None): request.url = self._client.format_url(request.url) else: - # make call to next link with the client's api-version - _parsed_next_link = urllib.parse.urlparse(next_link) - _next_request_params = case_insensitive_dict( - { - key: [urllib.parse.quote(v) for v in value] - for key, value in urllib.parse.parse_qs(_parsed_next_link.query).items() - } - ) - _next_request_params["api-version"] = self._config.api_version - request = HttpRequest( - "GET", urllib.parse.urljoin(next_link, _parsed_next_link.path), params=_next_request_params - ) + request = HttpRequest("GET", next_link) request = _convert_request(request) request.url = self._client.format_url(request.url) request.method = "GET" @@ -806,8 +794,8 @@ def list_by_subscription(self, **kwargs: Any) -> AsyncIterable["_models.AccessCo _headers = kwargs.pop("headers", {}) or {} _params = case_insensitive_dict(kwargs.pop("params", {}) or {}) - api_version: Literal["2022-04-01-preview"] = kwargs.pop( - "api_version", _params.pop("api-version", self._config.api_version) + api_version: Literal["2022-10-01-preview"] = kwargs.pop( + "api_version", _params.pop("api-version", "2022-10-01-preview") ) cls: ClsType[_models.AccessConnectorListResult] = kwargs.pop("cls", None) @@ -833,18 +821,7 @@ def prepare_request(next_link=None): request.url = self._client.format_url(request.url) else: - # make call to next link with the client's api-version - _parsed_next_link = urllib.parse.urlparse(next_link) - _next_request_params = case_insensitive_dict( - { - key: [urllib.parse.quote(v) for v in value] - for key, value in urllib.parse.parse_qs(_parsed_next_link.query).items() - } - ) - _next_request_params["api-version"] = self._config.api_version - request = HttpRequest( - "GET", urllib.parse.urljoin(next_link, _parsed_next_link.path), params=_next_request_params - ) + request = HttpRequest("GET", next_link) request = _convert_request(request) request.url = self._client.format_url(request.url) request.method = "GET" diff --git a/sdk/databricks/azure-mgmt-databricks/azure/mgmt/databricks/aio/operations/_operations.py b/sdk/databricks/azure-mgmt-databricks/azure/mgmt/databricks/aio/operations/_operations.py index c625981a031b..3758af62c66e 100644 --- a/sdk/databricks/azure-mgmt-databricks/azure/mgmt/databricks/aio/operations/_operations.py +++ b/sdk/databricks/azure-mgmt-databricks/azure/mgmt/databricks/aio/operations/_operations.py @@ -8,7 +8,6 @@ # -------------------------------------------------------------------------- import sys from typing import Any, AsyncIterable, Callable, Dict, Optional, TypeVar -import urllib.parse from azure.core.async_paging import AsyncItemPaged, AsyncList from azure.core.exceptions import ( @@ -70,7 +69,7 @@ def list(self, **kwargs: Any) -> AsyncIterable["_models.Operation"]: _params = case_insensitive_dict(kwargs.pop("params", {}) or {}) api_version: Literal["2022-04-01-preview"] = kwargs.pop( - "api_version", _params.pop("api-version", self._config.api_version) + "api_version", _params.pop("api-version", "2022-04-01-preview") ) cls: ClsType[_models.OperationListResult] = kwargs.pop("cls", None) @@ -95,18 +94,7 @@ def prepare_request(next_link=None): request.url = self._client.format_url(request.url) else: - # make call to next link with the client's api-version - _parsed_next_link = urllib.parse.urlparse(next_link) - _next_request_params = case_insensitive_dict( - { - key: [urllib.parse.quote(v) for v in value] - for key, value in urllib.parse.parse_qs(_parsed_next_link.query).items() - } - ) - _next_request_params["api-version"] = self._config.api_version - request = HttpRequest( - "GET", urllib.parse.urljoin(next_link, _parsed_next_link.path), params=_next_request_params - ) + request = HttpRequest("GET", next_link) request = _convert_request(request) request.url = self._client.format_url(request.url) request.method = "GET" diff --git a/sdk/databricks/azure-mgmt-databricks/azure/mgmt/databricks/aio/operations/_outbound_network_dependencies_endpoints_operations.py b/sdk/databricks/azure-mgmt-databricks/azure/mgmt/databricks/aio/operations/_outbound_network_dependencies_endpoints_operations.py index 52a2514648e3..9bf0591b2ebe 100644 --- a/sdk/databricks/azure-mgmt-databricks/azure/mgmt/databricks/aio/operations/_outbound_network_dependencies_endpoints_operations.py +++ b/sdk/databricks/azure-mgmt-databricks/azure/mgmt/databricks/aio/operations/_outbound_network_dependencies_endpoints_operations.py @@ -88,7 +88,7 @@ async def list( _params = case_insensitive_dict(kwargs.pop("params", {}) or {}) api_version: Literal["2022-04-01-preview"] = kwargs.pop( - "api_version", _params.pop("api-version", self._config.api_version) + "api_version", _params.pop("api-version", "2022-04-01-preview") ) cls: ClsType[List[_models.OutboundEnvironmentEndpoint]] = kwargs.pop("cls", None) diff --git a/sdk/databricks/azure-mgmt-databricks/azure/mgmt/databricks/aio/operations/_private_endpoint_connections_operations.py b/sdk/databricks/azure-mgmt-databricks/azure/mgmt/databricks/aio/operations/_private_endpoint_connections_operations.py index 006bce65c7d7..0a548e29e823 100644 --- a/sdk/databricks/azure-mgmt-databricks/azure/mgmt/databricks/aio/operations/_private_endpoint_connections_operations.py +++ b/sdk/databricks/azure-mgmt-databricks/azure/mgmt/databricks/aio/operations/_private_endpoint_connections_operations.py @@ -8,7 +8,6 @@ # -------------------------------------------------------------------------- import sys from typing import Any, AsyncIterable, Callable, Dict, IO, Optional, TypeVar, Union, cast, overload -import urllib.parse from azure.core.async_paging import AsyncItemPaged, AsyncList from azure.core.exceptions import ( @@ -89,7 +88,7 @@ def list( _params = case_insensitive_dict(kwargs.pop("params", {}) or {}) api_version: Literal["2022-04-01-preview"] = kwargs.pop( - "api_version", _params.pop("api-version", self._config.api_version) + "api_version", _params.pop("api-version", "2022-04-01-preview") ) cls: ClsType[_models.PrivateEndpointConnectionsList] = kwargs.pop("cls", None) @@ -117,18 +116,7 @@ def prepare_request(next_link=None): request.url = self._client.format_url(request.url) else: - # make call to next link with the client's api-version - _parsed_next_link = urllib.parse.urlparse(next_link) - _next_request_params = case_insensitive_dict( - { - key: [urllib.parse.quote(v) for v in value] - for key, value in urllib.parse.parse_qs(_parsed_next_link.query).items() - } - ) - _next_request_params["api-version"] = self._config.api_version - request = HttpRequest( - "GET", urllib.parse.urljoin(next_link, _parsed_next_link.path), params=_next_request_params - ) + request = HttpRequest("GET", next_link) request = _convert_request(request) request.url = self._client.format_url(request.url) request.method = "GET" @@ -194,7 +182,7 @@ async def get( _params = case_insensitive_dict(kwargs.pop("params", {}) or {}) api_version: Literal["2022-04-01-preview"] = kwargs.pop( - "api_version", _params.pop("api-version", self._config.api_version) + "api_version", _params.pop("api-version", "2022-04-01-preview") ) cls: ClsType[_models.PrivateEndpointConnection] = kwargs.pop("cls", None) @@ -253,7 +241,7 @@ async def _create_initial( _params = case_insensitive_dict(kwargs.pop("params", {}) or {}) api_version: Literal["2022-04-01-preview"] = kwargs.pop( - "api_version", _params.pop("api-version", self._config.api_version) + "api_version", _params.pop("api-version", "2022-04-01-preview") ) content_type: Optional[str] = kwargs.pop("content_type", _headers.pop("Content-Type", None)) cls: ClsType[_models.PrivateEndpointConnection] = kwargs.pop("cls", None) @@ -439,7 +427,7 @@ async def begin_create( _params = case_insensitive_dict(kwargs.pop("params", {}) or {}) api_version: Literal["2022-04-01-preview"] = kwargs.pop( - "api_version", _params.pop("api-version", self._config.api_version) + "api_version", _params.pop("api-version", "2022-04-01-preview") ) content_type: Optional[str] = kwargs.pop("content_type", _headers.pop("Content-Type", None)) cls: ClsType[_models.PrivateEndpointConnection] = kwargs.pop("cls", None) @@ -501,7 +489,7 @@ async def _delete_initial( # pylint: disable=inconsistent-return-statements _params = case_insensitive_dict(kwargs.pop("params", {}) or {}) api_version: Literal["2022-04-01-preview"] = kwargs.pop( - "api_version", _params.pop("api-version", self._config.api_version) + "api_version", _params.pop("api-version", "2022-04-01-preview") ) cls: ClsType[None] = kwargs.pop("cls", None) @@ -567,7 +555,7 @@ async def begin_delete( _params = case_insensitive_dict(kwargs.pop("params", {}) or {}) api_version: Literal["2022-04-01-preview"] = kwargs.pop( - "api_version", _params.pop("api-version", self._config.api_version) + "api_version", _params.pop("api-version", "2022-04-01-preview") ) cls: ClsType[None] = kwargs.pop("cls", None) polling: Union[bool, AsyncPollingMethod] = kwargs.pop("polling", True) diff --git a/sdk/databricks/azure-mgmt-databricks/azure/mgmt/databricks/aio/operations/_private_link_resources_operations.py b/sdk/databricks/azure-mgmt-databricks/azure/mgmt/databricks/aio/operations/_private_link_resources_operations.py index deba832e4752..9ec7d43c09ca 100644 --- a/sdk/databricks/azure-mgmt-databricks/azure/mgmt/databricks/aio/operations/_private_link_resources_operations.py +++ b/sdk/databricks/azure-mgmt-databricks/azure/mgmt/databricks/aio/operations/_private_link_resources_operations.py @@ -8,7 +8,6 @@ # -------------------------------------------------------------------------- import sys from typing import Any, AsyncIterable, Callable, Dict, Optional, TypeVar -import urllib.parse from azure.core.async_paging import AsyncItemPaged, AsyncList from azure.core.exceptions import ( @@ -81,7 +80,7 @@ def list( _params = case_insensitive_dict(kwargs.pop("params", {}) or {}) api_version: Literal["2022-04-01-preview"] = kwargs.pop( - "api_version", _params.pop("api-version", self._config.api_version) + "api_version", _params.pop("api-version", "2022-04-01-preview") ) cls: ClsType[_models.PrivateLinkResourcesList] = kwargs.pop("cls", None) @@ -109,18 +108,7 @@ def prepare_request(next_link=None): request.url = self._client.format_url(request.url) else: - # make call to next link with the client's api-version - _parsed_next_link = urllib.parse.urlparse(next_link) - _next_request_params = case_insensitive_dict( - { - key: [urllib.parse.quote(v) for v in value] - for key, value in urllib.parse.parse_qs(_parsed_next_link.query).items() - } - ) - _next_request_params["api-version"] = self._config.api_version - request = HttpRequest( - "GET", urllib.parse.urljoin(next_link, _parsed_next_link.path), params=_next_request_params - ) + request = HttpRequest("GET", next_link) request = _convert_request(request) request.url = self._client.format_url(request.url) request.method = "GET" @@ -186,7 +174,7 @@ async def get( _params = case_insensitive_dict(kwargs.pop("params", {}) or {}) api_version: Literal["2022-04-01-preview"] = kwargs.pop( - "api_version", _params.pop("api-version", self._config.api_version) + "api_version", _params.pop("api-version", "2022-04-01-preview") ) cls: ClsType[_models.GroupIdInformation] = kwargs.pop("cls", None) diff --git a/sdk/databricks/azure-mgmt-databricks/azure/mgmt/databricks/aio/operations/_vnet_peering_operations.py b/sdk/databricks/azure-mgmt-databricks/azure/mgmt/databricks/aio/operations/_vnet_peering_operations.py index 54afffddb762..09068198f597 100644 --- a/sdk/databricks/azure-mgmt-databricks/azure/mgmt/databricks/aio/operations/_vnet_peering_operations.py +++ b/sdk/databricks/azure-mgmt-databricks/azure/mgmt/databricks/aio/operations/_vnet_peering_operations.py @@ -8,7 +8,6 @@ # -------------------------------------------------------------------------- import sys from typing import Any, AsyncIterable, Callable, Dict, IO, Optional, TypeVar, Union, cast, overload -import urllib.parse from azure.core.async_paging import AsyncItemPaged, AsyncList from azure.core.exceptions import ( @@ -95,7 +94,7 @@ async def get( _params = case_insensitive_dict(kwargs.pop("params", {}) or {}) api_version: Literal["2022-04-01-preview"] = kwargs.pop( - "api_version", _params.pop("api-version", self._config.api_version) + "api_version", _params.pop("api-version", "2022-04-01-preview") ) cls: ClsType[Optional[_models.VirtualNetworkPeering]] = kwargs.pop("cls", None) @@ -151,7 +150,7 @@ async def _delete_initial( # pylint: disable=inconsistent-return-statements _params = case_insensitive_dict(kwargs.pop("params", {}) or {}) api_version: Literal["2022-04-01-preview"] = kwargs.pop( - "api_version", _params.pop("api-version", self._config.api_version) + "api_version", _params.pop("api-version", "2022-04-01-preview") ) cls: ClsType[None] = kwargs.pop("cls", None) @@ -215,7 +214,7 @@ async def begin_delete( _params = case_insensitive_dict(kwargs.pop("params", {}) or {}) api_version: Literal["2022-04-01-preview"] = kwargs.pop( - "api_version", _params.pop("api-version", self._config.api_version) + "api_version", _params.pop("api-version", "2022-04-01-preview") ) cls: ClsType[None] = kwargs.pop("cls", None) polling: Union[bool, AsyncPollingMethod] = kwargs.pop("polling", True) @@ -277,7 +276,7 @@ async def _create_or_update_initial( _params = case_insensitive_dict(kwargs.pop("params", {}) or {}) api_version: Literal["2022-04-01-preview"] = kwargs.pop( - "api_version", _params.pop("api-version", self._config.api_version) + "api_version", _params.pop("api-version", "2022-04-01-preview") ) content_type: Optional[str] = kwargs.pop("content_type", _headers.pop("Content-Type", None)) cls: ClsType[_models.VirtualNetworkPeering] = kwargs.pop("cls", None) @@ -454,7 +453,7 @@ async def begin_create_or_update( _params = case_insensitive_dict(kwargs.pop("params", {}) or {}) api_version: Literal["2022-04-01-preview"] = kwargs.pop( - "api_version", _params.pop("api-version", self._config.api_version) + "api_version", _params.pop("api-version", "2022-04-01-preview") ) content_type: Optional[str] = kwargs.pop("content_type", _headers.pop("Content-Type", None)) cls: ClsType[_models.VirtualNetworkPeering] = kwargs.pop("cls", None) @@ -523,7 +522,7 @@ def list_by_workspace( _params = case_insensitive_dict(kwargs.pop("params", {}) or {}) api_version: Literal["2022-04-01-preview"] = kwargs.pop( - "api_version", _params.pop("api-version", self._config.api_version) + "api_version", _params.pop("api-version", "2022-04-01-preview") ) cls: ClsType[_models.VirtualNetworkPeeringList] = kwargs.pop("cls", None) @@ -551,18 +550,7 @@ def prepare_request(next_link=None): request.url = self._client.format_url(request.url) else: - # make call to next link with the client's api-version - _parsed_next_link = urllib.parse.urlparse(next_link) - _next_request_params = case_insensitive_dict( - { - key: [urllib.parse.quote(v) for v in value] - for key, value in urllib.parse.parse_qs(_parsed_next_link.query).items() - } - ) - _next_request_params["api-version"] = self._config.api_version - request = HttpRequest( - "GET", urllib.parse.urljoin(next_link, _parsed_next_link.path), params=_next_request_params - ) + request = HttpRequest("GET", next_link) request = _convert_request(request) request.url = self._client.format_url(request.url) request.method = "GET" diff --git a/sdk/databricks/azure-mgmt-databricks/azure/mgmt/databricks/aio/operations/_workspaces_operations.py b/sdk/databricks/azure-mgmt-databricks/azure/mgmt/databricks/aio/operations/_workspaces_operations.py index 753a9f3a8864..91fe24c7a46d 100644 --- a/sdk/databricks/azure-mgmt-databricks/azure/mgmt/databricks/aio/operations/_workspaces_operations.py +++ b/sdk/databricks/azure-mgmt-databricks/azure/mgmt/databricks/aio/operations/_workspaces_operations.py @@ -8,7 +8,6 @@ # -------------------------------------------------------------------------- import sys from typing import Any, AsyncIterable, Callable, Dict, IO, Optional, TypeVar, Union, cast, overload -import urllib.parse from azure.core.async_paging import AsyncItemPaged, AsyncList from azure.core.exceptions import ( @@ -93,7 +92,7 @@ async def get(self, resource_group_name: str, workspace_name: str, **kwargs: Any _params = case_insensitive_dict(kwargs.pop("params", {}) or {}) api_version: Literal["2022-04-01-preview"] = kwargs.pop( - "api_version", _params.pop("api-version", self._config.api_version) + "api_version", _params.pop("api-version", "2022-04-01-preview") ) cls: ClsType[_models.Workspace] = kwargs.pop("cls", None) @@ -146,7 +145,7 @@ async def _delete_initial( # pylint: disable=inconsistent-return-statements _params = case_insensitive_dict(kwargs.pop("params", {}) or {}) api_version: Literal["2022-04-01-preview"] = kwargs.pop( - "api_version", _params.pop("api-version", self._config.api_version) + "api_version", _params.pop("api-version", "2022-04-01-preview") ) cls: ClsType[None] = kwargs.pop("cls", None) @@ -205,7 +204,7 @@ async def begin_delete(self, resource_group_name: str, workspace_name: str, **kw _params = case_insensitive_dict(kwargs.pop("params", {}) or {}) api_version: Literal["2022-04-01-preview"] = kwargs.pop( - "api_version", _params.pop("api-version", self._config.api_version) + "api_version", _params.pop("api-version", "2022-04-01-preview") ) cls: ClsType[None] = kwargs.pop("cls", None) polling: Union[bool, AsyncPollingMethod] = kwargs.pop("polling", True) @@ -261,7 +260,7 @@ async def _create_or_update_initial( _params = case_insensitive_dict(kwargs.pop("params", {}) or {}) api_version: Literal["2022-04-01-preview"] = kwargs.pop( - "api_version", _params.pop("api-version", self._config.api_version) + "api_version", _params.pop("api-version", "2022-04-01-preview") ) content_type: Optional[str] = kwargs.pop("content_type", _headers.pop("Content-Type", None)) cls: ClsType[_models.Workspace] = kwargs.pop("cls", None) @@ -421,7 +420,7 @@ async def begin_create_or_update( _params = case_insensitive_dict(kwargs.pop("params", {}) or {}) api_version: Literal["2022-04-01-preview"] = kwargs.pop( - "api_version", _params.pop("api-version", self._config.api_version) + "api_version", _params.pop("api-version", "2022-04-01-preview") ) content_type: Optional[str] = kwargs.pop("content_type", _headers.pop("Content-Type", None)) cls: ClsType[_models.Workspace] = kwargs.pop("cls", None) @@ -486,7 +485,7 @@ async def _update_initial( _params = case_insensitive_dict(kwargs.pop("params", {}) or {}) api_version: Literal["2022-04-01-preview"] = kwargs.pop( - "api_version", _params.pop("api-version", self._config.api_version) + "api_version", _params.pop("api-version", "2022-04-01-preview") ) content_type: Optional[str] = kwargs.pop("content_type", _headers.pop("Content-Type", None)) cls: ClsType[Optional[_models.Workspace]] = kwargs.pop("cls", None) @@ -647,7 +646,7 @@ async def begin_update( _params = case_insensitive_dict(kwargs.pop("params", {}) or {}) api_version: Literal["2022-04-01-preview"] = kwargs.pop( - "api_version", _params.pop("api-version", self._config.api_version) + "api_version", _params.pop("api-version", "2022-04-01-preview") ) content_type: Optional[str] = kwargs.pop("content_type", _headers.pop("Content-Type", None)) cls: ClsType[_models.Workspace] = kwargs.pop("cls", None) @@ -709,7 +708,7 @@ def list_by_resource_group(self, resource_group_name: str, **kwargs: Any) -> Asy _params = case_insensitive_dict(kwargs.pop("params", {}) or {}) api_version: Literal["2022-04-01-preview"] = kwargs.pop( - "api_version", _params.pop("api-version", self._config.api_version) + "api_version", _params.pop("api-version", "2022-04-01-preview") ) cls: ClsType[_models.WorkspaceListResult] = kwargs.pop("cls", None) @@ -736,18 +735,7 @@ def prepare_request(next_link=None): request.url = self._client.format_url(request.url) else: - # make call to next link with the client's api-version - _parsed_next_link = urllib.parse.urlparse(next_link) - _next_request_params = case_insensitive_dict( - { - key: [urllib.parse.quote(v) for v in value] - for key, value in urllib.parse.parse_qs(_parsed_next_link.query).items() - } - ) - _next_request_params["api-version"] = self._config.api_version - request = HttpRequest( - "GET", urllib.parse.urljoin(next_link, _parsed_next_link.path), params=_next_request_params - ) + request = HttpRequest("GET", next_link) request = _convert_request(request) request.url = self._client.format_url(request.url) request.method = "GET" @@ -794,7 +782,7 @@ def list_by_subscription(self, **kwargs: Any) -> AsyncIterable["_models.Workspac _params = case_insensitive_dict(kwargs.pop("params", {}) or {}) api_version: Literal["2022-04-01-preview"] = kwargs.pop( - "api_version", _params.pop("api-version", self._config.api_version) + "api_version", _params.pop("api-version", "2022-04-01-preview") ) cls: ClsType[_models.WorkspaceListResult] = kwargs.pop("cls", None) @@ -820,18 +808,7 @@ def prepare_request(next_link=None): request.url = self._client.format_url(request.url) else: - # make call to next link with the client's api-version - _parsed_next_link = urllib.parse.urlparse(next_link) - _next_request_params = case_insensitive_dict( - { - key: [urllib.parse.quote(v) for v in value] - for key, value in urllib.parse.parse_qs(_parsed_next_link.query).items() - } - ) - _next_request_params["api-version"] = self._config.api_version - request = HttpRequest( - "GET", urllib.parse.urljoin(next_link, _parsed_next_link.path), params=_next_request_params - ) + request = HttpRequest("GET", next_link) request = _convert_request(request) request.url = self._client.format_url(request.url) request.method = "GET" diff --git a/sdk/databricks/azure-mgmt-databricks/azure/mgmt/databricks/models/__init__.py b/sdk/databricks/azure-mgmt-databricks/azure/mgmt/databricks/models/__init__.py index a167f64ff43e..ac37825003f8 100644 --- a/sdk/databricks/azure-mgmt-databricks/azure/mgmt/databricks/models/__init__.py +++ b/sdk/databricks/azure-mgmt-databricks/azure/mgmt/databricks/models/__init__.py @@ -23,10 +23,10 @@ from ._models_py3 import ErrorResponse from ._models_py3 import GroupIdInformation from ._models_py3 import GroupIdInformationProperties -from ._models_py3 import IdentityData from ._models_py3 import ManagedDiskEncryption from ._models_py3 import ManagedDiskEncryptionKeyVaultProperties from ._models_py3 import ManagedIdentityConfiguration +from ._models_py3 import ManagedServiceIdentity from ._models_py3 import Operation from ._models_py3 import OperationDisplay from ._models_py3 import OperationListResult @@ -41,6 +41,7 @@ from ._models_py3 import Sku from ._models_py3 import SystemData from ._models_py3 import TrackedResource +from ._models_py3 import UserAssignedIdentity from ._models_py3 import VirtualNetworkPeering from ._models_py3 import VirtualNetworkPeeringList from ._models_py3 import VirtualNetworkPeeringPropertiesFormatDatabricksVirtualNetwork @@ -59,8 +60,8 @@ from ._azure_databricks_management_client_enums import CreatedByType from ._azure_databricks_management_client_enums import CustomParameterType from ._azure_databricks_management_client_enums import EncryptionKeySource -from ._azure_databricks_management_client_enums import IdentityType from ._azure_databricks_management_client_enums import KeySource +from ._azure_databricks_management_client_enums import ManagedServiceIdentityType from ._azure_databricks_management_client_enums import PeeringProvisioningState from ._azure_databricks_management_client_enums import PeeringState from ._azure_databricks_management_client_enums import PrivateEndpointConnectionProvisioningState @@ -90,10 +91,10 @@ "ErrorResponse", "GroupIdInformation", "GroupIdInformationProperties", - "IdentityData", "ManagedDiskEncryption", "ManagedDiskEncryptionKeyVaultProperties", "ManagedIdentityConfiguration", + "ManagedServiceIdentity", "Operation", "OperationDisplay", "OperationListResult", @@ -108,6 +109,7 @@ "Sku", "SystemData", "TrackedResource", + "UserAssignedIdentity", "VirtualNetworkPeering", "VirtualNetworkPeeringList", "VirtualNetworkPeeringPropertiesFormatDatabricksVirtualNetwork", @@ -125,8 +127,8 @@ "CreatedByType", "CustomParameterType", "EncryptionKeySource", - "IdentityType", "KeySource", + "ManagedServiceIdentityType", "PeeringProvisioningState", "PeeringState", "PrivateEndpointConnectionProvisioningState", diff --git a/sdk/databricks/azure-mgmt-databricks/azure/mgmt/databricks/models/_azure_databricks_management_client_enums.py b/sdk/databricks/azure-mgmt-databricks/azure/mgmt/databricks/models/_azure_databricks_management_client_enums.py index 9f03ff71b49a..d2c537b8f206 100644 --- a/sdk/databricks/azure-mgmt-databricks/azure/mgmt/databricks/models/_azure_databricks_management_client_enums.py +++ b/sdk/databricks/azure-mgmt-databricks/azure/mgmt/databricks/models/_azure_databricks_management_client_enums.py @@ -33,13 +33,6 @@ class EncryptionKeySource(str, Enum, metaclass=CaseInsensitiveEnumMeta): MICROSOFT_KEYVAULT = "Microsoft.Keyvault" -class IdentityType(str, Enum, metaclass=CaseInsensitiveEnumMeta): - """The identity type.""" - - NONE = "None" - SYSTEM_ASSIGNED = "SystemAssigned" - - class KeySource(str, Enum, metaclass=CaseInsensitiveEnumMeta): """The encryption keySource (provider). Possible values (case-insensitive): Default, Microsoft.Keyvault. @@ -49,6 +42,17 @@ class KeySource(str, Enum, metaclass=CaseInsensitiveEnumMeta): MICROSOFT_KEYVAULT = "Microsoft.Keyvault" +class ManagedServiceIdentityType(str, Enum, metaclass=CaseInsensitiveEnumMeta): + """Type of managed service identity (where both SystemAssigned and UserAssigned types are + allowed). + """ + + NONE = "None" + SYSTEM_ASSIGNED = "SystemAssigned" + USER_ASSIGNED = "UserAssigned" + SYSTEM_ASSIGNED_USER_ASSIGNED = "SystemAssigned,UserAssigned" + + class PeeringProvisioningState(str, Enum, metaclass=CaseInsensitiveEnumMeta): """The current provisioning state.""" diff --git a/sdk/databricks/azure-mgmt-databricks/azure/mgmt/databricks/models/_models_py3.py b/sdk/databricks/azure-mgmt-databricks/azure/mgmt/databricks/models/_models_py3.py index 79901cc3e9b5..04f0774cfca1 100644 --- a/sdk/databricks/azure-mgmt-databricks/azure/mgmt/databricks/models/_models_py3.py +++ b/sdk/databricks/azure-mgmt-databricks/azure/mgmt/databricks/models/_models_py3.py @@ -126,8 +126,10 @@ class AccessConnector(TrackedResource): :vartype tags: dict[str, str] :ivar location: The geo-location where the resource lives. Required. :vartype location: str - :ivar identity: Identity for the resource. - :vartype identity: ~azure.mgmt.databricks.models.IdentityData + :ivar identity: Managed service identity (system assigned and/or user assigned identities). + :vartype identity: ~azure.mgmt.databricks.models.ManagedServiceIdentity + :ivar system_data: The system metadata relating to this resource. + :vartype system_data: ~azure.mgmt.databricks.models.SystemData :ivar properties: Azure Databricks accessConnector properties. :vartype properties: ~azure.mgmt.databricks.models.AccessConnectorProperties """ @@ -137,6 +139,7 @@ class AccessConnector(TrackedResource): "name": {"readonly": True}, "type": {"readonly": True}, "location": {"required": True}, + "system_data": {"readonly": True}, } _attribute_map = { @@ -145,7 +148,8 @@ class AccessConnector(TrackedResource): "type": {"key": "type", "type": "str"}, "tags": {"key": "tags", "type": "{str}"}, "location": {"key": "location", "type": "str"}, - "identity": {"key": "identity", "type": "IdentityData"}, + "identity": {"key": "identity", "type": "ManagedServiceIdentity"}, + "system_data": {"key": "systemData", "type": "SystemData"}, "properties": {"key": "properties", "type": "AccessConnectorProperties"}, } @@ -154,7 +158,7 @@ def __init__( *, location: str, tags: Optional[Dict[str, str]] = None, - identity: Optional["_models.IdentityData"] = None, + identity: Optional["_models.ManagedServiceIdentity"] = None, properties: Optional["_models.AccessConnectorProperties"] = None, **kwargs ): @@ -163,13 +167,14 @@ def __init__( :paramtype tags: dict[str, str] :keyword location: The geo-location where the resource lives. Required. :paramtype location: str - :keyword identity: Identity for the resource. - :paramtype identity: ~azure.mgmt.databricks.models.IdentityData + :keyword identity: Managed service identity (system assigned and/or user assigned identities). + :paramtype identity: ~azure.mgmt.databricks.models.ManagedServiceIdentity :keyword properties: Azure Databricks accessConnector properties. :paramtype properties: ~azure.mgmt.databricks.models.AccessConnectorProperties """ super().__init__(tags=tags, location=location, **kwargs) self.identity = identity + self.system_data = None self.properties = properties @@ -231,23 +236,27 @@ class AccessConnectorUpdate(_serialization.Model): :ivar tags: Resource tags. :vartype tags: dict[str, str] - :ivar identity: The identity of the resource. - :vartype identity: ~azure.mgmt.databricks.models.IdentityData + :ivar identity: Managed service identity (system assigned and/or user assigned identities). + :vartype identity: ~azure.mgmt.databricks.models.ManagedServiceIdentity """ _attribute_map = { "tags": {"key": "tags", "type": "{str}"}, - "identity": {"key": "identity", "type": "IdentityData"}, + "identity": {"key": "identity", "type": "ManagedServiceIdentity"}, } def __init__( - self, *, tags: Optional[Dict[str, str]] = None, identity: Optional["_models.IdentityData"] = None, **kwargs + self, + *, + tags: Optional[Dict[str, str]] = None, + identity: Optional["_models.ManagedServiceIdentity"] = None, + **kwargs ): """ :keyword tags: Resource tags. :paramtype tags: dict[str, str] - :keyword identity: The identity of the resource. - :paramtype identity: ~azure.mgmt.databricks.models.IdentityData + :keyword identity: Managed service identity (system assigned and/or user assigned identities). + :paramtype identity: ~azure.mgmt.databricks.models.ManagedServiceIdentity """ super().__init__(**kwargs) self.tags = tags @@ -751,44 +760,6 @@ def __init__( self.required_zone_names = required_zone_names -class IdentityData(_serialization.Model): - """Identity for the resource. - - Variables are only populated by the server, and will be ignored when sending a request. - - All required parameters must be populated in order to send to Azure. - - :ivar principal_id: The principal ID of resource identity. - :vartype principal_id: str - :ivar tenant_id: The tenant ID of resource. - :vartype tenant_id: str - :ivar type: The identity type. Required. Known values are: "None" and "SystemAssigned". - :vartype type: str or ~azure.mgmt.databricks.models.IdentityType - """ - - _validation = { - "principal_id": {"readonly": True}, - "tenant_id": {"readonly": True}, - "type": {"required": True}, - } - - _attribute_map = { - "principal_id": {"key": "principalId", "type": "str"}, - "tenant_id": {"key": "tenantId", "type": "str"}, - "type": {"key": "type", "type": "str"}, - } - - def __init__(self, *, type: Union[str, "_models.IdentityType"], **kwargs): - """ - :keyword type: The identity type. Required. Known values are: "None" and "SystemAssigned". - :paramtype type: str or ~azure.mgmt.databricks.models.IdentityType - """ - super().__init__(**kwargs) - self.principal_id = None - self.tenant_id = None - self.type = type - - class ManagedDiskEncryption(_serialization.Model): """The object that contains details of encryption used on the workspace. @@ -915,6 +886,70 @@ def __init__(self, **kwargs): self.type = None +class ManagedServiceIdentity(_serialization.Model): + """Managed service identity (system assigned and/or user assigned identities). + + Variables are only populated by the server, and will be ignored when sending a request. + + All required parameters must be populated in order to send to Azure. + + :ivar principal_id: The service principal ID of the system assigned identity. This property + will only be provided for a system assigned identity. + :vartype principal_id: str + :ivar tenant_id: The tenant ID of the system assigned identity. This property will only be + provided for a system assigned identity. + :vartype tenant_id: str + :ivar type: Type of managed service identity (where both SystemAssigned and UserAssigned types + are allowed). Required. Known values are: "None", "SystemAssigned", "UserAssigned", and + "SystemAssigned,UserAssigned". + :vartype type: str or ~azure.mgmt.databricks.models.ManagedServiceIdentityType + :ivar user_assigned_identities: The set of user assigned identities associated with the + resource. The userAssignedIdentities dictionary keys will be ARM resource ids in the form: + '/subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/Microsoft.ManagedIdentity/userAssignedIdentities/{identityName}. + The dictionary values can be empty objects ({}) in requests. + :vartype user_assigned_identities: dict[str, + ~azure.mgmt.databricks.models.UserAssignedIdentity] + """ + + _validation = { + "principal_id": {"readonly": True}, + "tenant_id": {"readonly": True}, + "type": {"required": True}, + } + + _attribute_map = { + "principal_id": {"key": "principalId", "type": "str"}, + "tenant_id": {"key": "tenantId", "type": "str"}, + "type": {"key": "type", "type": "str"}, + "user_assigned_identities": {"key": "userAssignedIdentities", "type": "{UserAssignedIdentity}"}, + } + + def __init__( + self, + *, + type: Union[str, "_models.ManagedServiceIdentityType"], + user_assigned_identities: Optional[Dict[str, "_models.UserAssignedIdentity"]] = None, + **kwargs + ): + """ + :keyword type: Type of managed service identity (where both SystemAssigned and UserAssigned + types are allowed). Required. Known values are: "None", "SystemAssigned", "UserAssigned", and + "SystemAssigned,UserAssigned". + :paramtype type: str or ~azure.mgmt.databricks.models.ManagedServiceIdentityType + :keyword user_assigned_identities: The set of user assigned identities associated with the + resource. The userAssignedIdentities dictionary keys will be ARM resource ids in the form: + '/subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/Microsoft.ManagedIdentity/userAssignedIdentities/{identityName}. + The dictionary values can be empty objects ({}) in requests. + :paramtype user_assigned_identities: dict[str, + ~azure.mgmt.databricks.models.UserAssignedIdentity] + """ + super().__init__(**kwargs) + self.principal_id = None + self.tenant_id = None + self.type = type + self.user_assigned_identities = user_assigned_identities + + class Operation(_serialization.Model): """REST API operation. @@ -1363,6 +1398,34 @@ def __init__( self.last_modified_at = last_modified_at +class UserAssignedIdentity(_serialization.Model): + """User assigned identity properties. + + Variables are only populated by the server, and will be ignored when sending a request. + + :ivar principal_id: The principal ID of the assigned identity. + :vartype principal_id: str + :ivar client_id: The client ID of the assigned identity. + :vartype client_id: str + """ + + _validation = { + "principal_id": {"readonly": True}, + "client_id": {"readonly": True}, + } + + _attribute_map = { + "principal_id": {"key": "principalId", "type": "str"}, + "client_id": {"key": "clientId", "type": "str"}, + } + + def __init__(self, **kwargs): + """ """ + super().__init__(**kwargs) + self.principal_id = None + self.client_id = None + + class VirtualNetworkPeering(_serialization.Model): # pylint: disable=too-many-instance-attributes """Peerings in a VirtualNetwork resource. diff --git a/sdk/databricks/azure-mgmt-databricks/azure/mgmt/databricks/operations/__init__.py b/sdk/databricks/azure-mgmt-databricks/azure/mgmt/databricks/operations/__init__.py index fb2a003837b4..6ea78842aacf 100644 --- a/sdk/databricks/azure-mgmt-databricks/azure/mgmt/databricks/operations/__init__.py +++ b/sdk/databricks/azure-mgmt-databricks/azure/mgmt/databricks/operations/__init__.py @@ -6,26 +6,26 @@ # Changes may cause incorrect behavior and will be lost if the code is regenerated. # -------------------------------------------------------------------------- +from ._access_connectors_operations import AccessConnectorsOperations from ._workspaces_operations import WorkspacesOperations from ._operations import Operations from ._private_link_resources_operations import PrivateLinkResourcesOperations from ._private_endpoint_connections_operations import PrivateEndpointConnectionsOperations from ._outbound_network_dependencies_endpoints_operations import OutboundNetworkDependenciesEndpointsOperations from ._vnet_peering_operations import VNetPeeringOperations -from ._access_connectors_operations import AccessConnectorsOperations from ._patch import __all__ as _patch_all from ._patch import * # pylint: disable=unused-wildcard-import from ._patch import patch_sdk as _patch_sdk __all__ = [ + "AccessConnectorsOperations", "WorkspacesOperations", "Operations", "PrivateLinkResourcesOperations", "PrivateEndpointConnectionsOperations", "OutboundNetworkDependenciesEndpointsOperations", "VNetPeeringOperations", - "AccessConnectorsOperations", ] __all__.extend([p for p in _patch_all if p not in __all__]) _patch_sdk() diff --git a/sdk/databricks/azure-mgmt-databricks/azure/mgmt/databricks/operations/_access_connectors_operations.py b/sdk/databricks/azure-mgmt-databricks/azure/mgmt/databricks/operations/_access_connectors_operations.py index 15300c39c535..376d77adcf35 100644 --- a/sdk/databricks/azure-mgmt-databricks/azure/mgmt/databricks/operations/_access_connectors_operations.py +++ b/sdk/databricks/azure-mgmt-databricks/azure/mgmt/databricks/operations/_access_connectors_operations.py @@ -8,7 +8,6 @@ # -------------------------------------------------------------------------- import sys from typing import Any, Callable, Dict, IO, Iterable, Optional, TypeVar, Union, cast, overload -import urllib.parse from azure.core.exceptions import ( ClientAuthenticationError, @@ -49,8 +48,8 @@ def build_get_request( _headers = case_insensitive_dict(kwargs.pop("headers", {}) or {}) _params = case_insensitive_dict(kwargs.pop("params", {}) or {}) - api_version: Literal["2022-04-01-preview"] = kwargs.pop( - "api_version", _params.pop("api-version", "2022-04-01-preview") + api_version: Literal["2022-10-01-preview"] = kwargs.pop( + "api_version", _params.pop("api-version", "2022-10-01-preview") ) accept = _headers.pop("Accept", "application/json") @@ -84,8 +83,8 @@ def build_delete_request( _headers = case_insensitive_dict(kwargs.pop("headers", {}) or {}) _params = case_insensitive_dict(kwargs.pop("params", {}) or {}) - api_version: Literal["2022-04-01-preview"] = kwargs.pop( - "api_version", _params.pop("api-version", "2022-04-01-preview") + api_version: Literal["2022-10-01-preview"] = kwargs.pop( + "api_version", _params.pop("api-version", "2022-10-01-preview") ) accept = _headers.pop("Accept", "application/json") @@ -119,8 +118,8 @@ def build_create_or_update_request( _headers = case_insensitive_dict(kwargs.pop("headers", {}) or {}) _params = case_insensitive_dict(kwargs.pop("params", {}) or {}) - api_version: Literal["2022-04-01-preview"] = kwargs.pop( - "api_version", _params.pop("api-version", "2022-04-01-preview") + api_version: Literal["2022-10-01-preview"] = kwargs.pop( + "api_version", _params.pop("api-version", "2022-10-01-preview") ) content_type: Optional[str] = kwargs.pop("content_type", _headers.pop("Content-Type", None)) accept = _headers.pop("Accept", "application/json") @@ -157,8 +156,8 @@ def build_update_request( _headers = case_insensitive_dict(kwargs.pop("headers", {}) or {}) _params = case_insensitive_dict(kwargs.pop("params", {}) or {}) - api_version: Literal["2022-04-01-preview"] = kwargs.pop( - "api_version", _params.pop("api-version", "2022-04-01-preview") + api_version: Literal["2022-10-01-preview"] = kwargs.pop( + "api_version", _params.pop("api-version", "2022-10-01-preview") ) content_type: Optional[str] = kwargs.pop("content_type", _headers.pop("Content-Type", None)) accept = _headers.pop("Accept", "application/json") @@ -193,8 +192,8 @@ def build_list_by_resource_group_request(resource_group_name: str, subscription_ _headers = case_insensitive_dict(kwargs.pop("headers", {}) or {}) _params = case_insensitive_dict(kwargs.pop("params", {}) or {}) - api_version: Literal["2022-04-01-preview"] = kwargs.pop( - "api_version", _params.pop("api-version", "2022-04-01-preview") + api_version: Literal["2022-10-01-preview"] = kwargs.pop( + "api_version", _params.pop("api-version", "2022-10-01-preview") ) accept = _headers.pop("Accept", "application/json") @@ -225,8 +224,8 @@ def build_list_by_subscription_request(subscription_id: str, **kwargs: Any) -> H _headers = case_insensitive_dict(kwargs.pop("headers", {}) or {}) _params = case_insensitive_dict(kwargs.pop("params", {}) or {}) - api_version: Literal["2022-04-01-preview"] = kwargs.pop( - "api_version", _params.pop("api-version", "2022-04-01-preview") + api_version: Literal["2022-10-01-preview"] = kwargs.pop( + "api_version", _params.pop("api-version", "2022-10-01-preview") ) accept = _headers.pop("Accept", "application/json") @@ -291,8 +290,8 @@ def get(self, resource_group_name: str, connector_name: str, **kwargs: Any) -> _ _headers = kwargs.pop("headers", {}) or {} _params = case_insensitive_dict(kwargs.pop("params", {}) or {}) - api_version: Literal["2022-04-01-preview"] = kwargs.pop( - "api_version", _params.pop("api-version", self._config.api_version) + api_version: Literal["2022-10-01-preview"] = kwargs.pop( + "api_version", _params.pop("api-version", "2022-10-01-preview") ) cls: ClsType[_models.AccessConnector] = kwargs.pop("cls", None) @@ -344,8 +343,8 @@ def _delete_initial( # pylint: disable=inconsistent-return-statements _headers = kwargs.pop("headers", {}) or {} _params = case_insensitive_dict(kwargs.pop("params", {}) or {}) - api_version: Literal["2022-04-01-preview"] = kwargs.pop( - "api_version", _params.pop("api-version", self._config.api_version) + api_version: Literal["2022-10-01-preview"] = kwargs.pop( + "api_version", _params.pop("api-version", "2022-10-01-preview") ) cls: ClsType[None] = kwargs.pop("cls", None) @@ -403,8 +402,8 @@ def begin_delete(self, resource_group_name: str, connector_name: str, **kwargs: _headers = kwargs.pop("headers", {}) or {} _params = case_insensitive_dict(kwargs.pop("params", {}) or {}) - api_version: Literal["2022-04-01-preview"] = kwargs.pop( - "api_version", _params.pop("api-version", self._config.api_version) + api_version: Literal["2022-10-01-preview"] = kwargs.pop( + "api_version", _params.pop("api-version", "2022-10-01-preview") ) cls: ClsType[None] = kwargs.pop("cls", None) polling: Union[bool, PollingMethod] = kwargs.pop("polling", True) @@ -463,8 +462,8 @@ def _create_or_update_initial( _headers = case_insensitive_dict(kwargs.pop("headers", {}) or {}) _params = case_insensitive_dict(kwargs.pop("params", {}) or {}) - api_version: Literal["2022-04-01-preview"] = kwargs.pop( - "api_version", _params.pop("api-version", self._config.api_version) + api_version: Literal["2022-10-01-preview"] = kwargs.pop( + "api_version", _params.pop("api-version", "2022-10-01-preview") ) content_type: Optional[str] = kwargs.pop("content_type", _headers.pop("Content-Type", None)) cls: ClsType[_models.AccessConnector] = kwargs.pop("cls", None) @@ -629,8 +628,8 @@ def begin_create_or_update( _headers = case_insensitive_dict(kwargs.pop("headers", {}) or {}) _params = case_insensitive_dict(kwargs.pop("params", {}) or {}) - api_version: Literal["2022-04-01-preview"] = kwargs.pop( - "api_version", _params.pop("api-version", self._config.api_version) + api_version: Literal["2022-10-01-preview"] = kwargs.pop( + "api_version", _params.pop("api-version", "2022-10-01-preview") ) content_type: Optional[str] = kwargs.pop("content_type", _headers.pop("Content-Type", None)) cls: ClsType[_models.AccessConnector] = kwargs.pop("cls", None) @@ -694,8 +693,8 @@ def _update_initial( _headers = case_insensitive_dict(kwargs.pop("headers", {}) or {}) _params = case_insensitive_dict(kwargs.pop("params", {}) or {}) - api_version: Literal["2022-04-01-preview"] = kwargs.pop( - "api_version", _params.pop("api-version", self._config.api_version) + api_version: Literal["2022-10-01-preview"] = kwargs.pop( + "api_version", _params.pop("api-version", "2022-10-01-preview") ) content_type: Optional[str] = kwargs.pop("content_type", _headers.pop("Content-Type", None)) cls: ClsType[Optional[_models.AccessConnector]] = kwargs.pop("cls", None) @@ -856,8 +855,8 @@ def begin_update( _headers = case_insensitive_dict(kwargs.pop("headers", {}) or {}) _params = case_insensitive_dict(kwargs.pop("params", {}) or {}) - api_version: Literal["2022-04-01-preview"] = kwargs.pop( - "api_version", _params.pop("api-version", self._config.api_version) + api_version: Literal["2022-10-01-preview"] = kwargs.pop( + "api_version", _params.pop("api-version", "2022-10-01-preview") ) content_type: Optional[str] = kwargs.pop("content_type", _headers.pop("Content-Type", None)) cls: ClsType[_models.AccessConnector] = kwargs.pop("cls", None) @@ -918,8 +917,8 @@ def list_by_resource_group(self, resource_group_name: str, **kwargs: Any) -> Ite _headers = kwargs.pop("headers", {}) or {} _params = case_insensitive_dict(kwargs.pop("params", {}) or {}) - api_version: Literal["2022-04-01-preview"] = kwargs.pop( - "api_version", _params.pop("api-version", self._config.api_version) + api_version: Literal["2022-10-01-preview"] = kwargs.pop( + "api_version", _params.pop("api-version", "2022-10-01-preview") ) cls: ClsType[_models.AccessConnectorListResult] = kwargs.pop("cls", None) @@ -946,18 +945,7 @@ def prepare_request(next_link=None): request.url = self._client.format_url(request.url) else: - # make call to next link with the client's api-version - _parsed_next_link = urllib.parse.urlparse(next_link) - _next_request_params = case_insensitive_dict( - { - key: [urllib.parse.quote(v) for v in value] - for key, value in urllib.parse.parse_qs(_parsed_next_link.query).items() - } - ) - _next_request_params["api-version"] = self._config.api_version - request = HttpRequest( - "GET", urllib.parse.urljoin(next_link, _parsed_next_link.path), params=_next_request_params - ) + request = HttpRequest("GET", next_link) request = _convert_request(request) request.url = self._client.format_url(request.url) request.method = "GET" @@ -1003,8 +991,8 @@ def list_by_subscription(self, **kwargs: Any) -> Iterable["_models.AccessConnect _headers = kwargs.pop("headers", {}) or {} _params = case_insensitive_dict(kwargs.pop("params", {}) or {}) - api_version: Literal["2022-04-01-preview"] = kwargs.pop( - "api_version", _params.pop("api-version", self._config.api_version) + api_version: Literal["2022-10-01-preview"] = kwargs.pop( + "api_version", _params.pop("api-version", "2022-10-01-preview") ) cls: ClsType[_models.AccessConnectorListResult] = kwargs.pop("cls", None) @@ -1030,18 +1018,7 @@ def prepare_request(next_link=None): request.url = self._client.format_url(request.url) else: - # make call to next link with the client's api-version - _parsed_next_link = urllib.parse.urlparse(next_link) - _next_request_params = case_insensitive_dict( - { - key: [urllib.parse.quote(v) for v in value] - for key, value in urllib.parse.parse_qs(_parsed_next_link.query).items() - } - ) - _next_request_params["api-version"] = self._config.api_version - request = HttpRequest( - "GET", urllib.parse.urljoin(next_link, _parsed_next_link.path), params=_next_request_params - ) + request = HttpRequest("GET", next_link) request = _convert_request(request) request.url = self._client.format_url(request.url) request.method = "GET" diff --git a/sdk/databricks/azure-mgmt-databricks/azure/mgmt/databricks/operations/_operations.py b/sdk/databricks/azure-mgmt-databricks/azure/mgmt/databricks/operations/_operations.py index 834dc40285f9..65e57f9cd7b4 100644 --- a/sdk/databricks/azure-mgmt-databricks/azure/mgmt/databricks/operations/_operations.py +++ b/sdk/databricks/azure-mgmt-databricks/azure/mgmt/databricks/operations/_operations.py @@ -8,7 +8,6 @@ # -------------------------------------------------------------------------- import sys from typing import Any, Callable, Dict, Iterable, Optional, TypeVar -import urllib.parse from azure.core.exceptions import ( ClientAuthenticationError, @@ -94,7 +93,7 @@ def list(self, **kwargs: Any) -> Iterable["_models.Operation"]: _params = case_insensitive_dict(kwargs.pop("params", {}) or {}) api_version: Literal["2022-04-01-preview"] = kwargs.pop( - "api_version", _params.pop("api-version", self._config.api_version) + "api_version", _params.pop("api-version", "2022-04-01-preview") ) cls: ClsType[_models.OperationListResult] = kwargs.pop("cls", None) @@ -119,18 +118,7 @@ def prepare_request(next_link=None): request.url = self._client.format_url(request.url) else: - # make call to next link with the client's api-version - _parsed_next_link = urllib.parse.urlparse(next_link) - _next_request_params = case_insensitive_dict( - { - key: [urllib.parse.quote(v) for v in value] - for key, value in urllib.parse.parse_qs(_parsed_next_link.query).items() - } - ) - _next_request_params["api-version"] = self._config.api_version - request = HttpRequest( - "GET", urllib.parse.urljoin(next_link, _parsed_next_link.path), params=_next_request_params - ) + request = HttpRequest("GET", next_link) request = _convert_request(request) request.url = self._client.format_url(request.url) request.method = "GET" diff --git a/sdk/databricks/azure-mgmt-databricks/azure/mgmt/databricks/operations/_outbound_network_dependencies_endpoints_operations.py b/sdk/databricks/azure-mgmt-databricks/azure/mgmt/databricks/operations/_outbound_network_dependencies_endpoints_operations.py index ac4d7072014e..bb0eabe9628d 100644 --- a/sdk/databricks/azure-mgmt-databricks/azure/mgmt/databricks/operations/_outbound_network_dependencies_endpoints_operations.py +++ b/sdk/databricks/azure-mgmt-databricks/azure/mgmt/databricks/operations/_outbound_network_dependencies_endpoints_operations.py @@ -126,7 +126,7 @@ def list( _params = case_insensitive_dict(kwargs.pop("params", {}) or {}) api_version: Literal["2022-04-01-preview"] = kwargs.pop( - "api_version", _params.pop("api-version", self._config.api_version) + "api_version", _params.pop("api-version", "2022-04-01-preview") ) cls: ClsType[List[_models.OutboundEnvironmentEndpoint]] = kwargs.pop("cls", None) diff --git a/sdk/databricks/azure-mgmt-databricks/azure/mgmt/databricks/operations/_private_endpoint_connections_operations.py b/sdk/databricks/azure-mgmt-databricks/azure/mgmt/databricks/operations/_private_endpoint_connections_operations.py index 111dbdbacb95..8fe3559e837a 100644 --- a/sdk/databricks/azure-mgmt-databricks/azure/mgmt/databricks/operations/_private_endpoint_connections_operations.py +++ b/sdk/databricks/azure-mgmt-databricks/azure/mgmt/databricks/operations/_private_endpoint_connections_operations.py @@ -8,7 +8,6 @@ # -------------------------------------------------------------------------- import sys from typing import Any, Callable, Dict, IO, Iterable, Optional, TypeVar, Union, cast, overload -import urllib.parse from azure.core.exceptions import ( ClientAuthenticationError, @@ -249,7 +248,7 @@ def list( _params = case_insensitive_dict(kwargs.pop("params", {}) or {}) api_version: Literal["2022-04-01-preview"] = kwargs.pop( - "api_version", _params.pop("api-version", self._config.api_version) + "api_version", _params.pop("api-version", "2022-04-01-preview") ) cls: ClsType[_models.PrivateEndpointConnectionsList] = kwargs.pop("cls", None) @@ -277,18 +276,7 @@ def prepare_request(next_link=None): request.url = self._client.format_url(request.url) else: - # make call to next link with the client's api-version - _parsed_next_link = urllib.parse.urlparse(next_link) - _next_request_params = case_insensitive_dict( - { - key: [urllib.parse.quote(v) for v in value] - for key, value in urllib.parse.parse_qs(_parsed_next_link.query).items() - } - ) - _next_request_params["api-version"] = self._config.api_version - request = HttpRequest( - "GET", urllib.parse.urljoin(next_link, _parsed_next_link.path), params=_next_request_params - ) + request = HttpRequest("GET", next_link) request = _convert_request(request) request.url = self._client.format_url(request.url) request.method = "GET" @@ -354,7 +342,7 @@ def get( _params = case_insensitive_dict(kwargs.pop("params", {}) or {}) api_version: Literal["2022-04-01-preview"] = kwargs.pop( - "api_version", _params.pop("api-version", self._config.api_version) + "api_version", _params.pop("api-version", "2022-04-01-preview") ) cls: ClsType[_models.PrivateEndpointConnection] = kwargs.pop("cls", None) @@ -413,7 +401,7 @@ def _create_initial( _params = case_insensitive_dict(kwargs.pop("params", {}) or {}) api_version: Literal["2022-04-01-preview"] = kwargs.pop( - "api_version", _params.pop("api-version", self._config.api_version) + "api_version", _params.pop("api-version", "2022-04-01-preview") ) content_type: Optional[str] = kwargs.pop("content_type", _headers.pop("Content-Type", None)) cls: ClsType[_models.PrivateEndpointConnection] = kwargs.pop("cls", None) @@ -596,7 +584,7 @@ def begin_create( _params = case_insensitive_dict(kwargs.pop("params", {}) or {}) api_version: Literal["2022-04-01-preview"] = kwargs.pop( - "api_version", _params.pop("api-version", self._config.api_version) + "api_version", _params.pop("api-version", "2022-04-01-preview") ) content_type: Optional[str] = kwargs.pop("content_type", _headers.pop("Content-Type", None)) cls: ClsType[_models.PrivateEndpointConnection] = kwargs.pop("cls", None) @@ -658,7 +646,7 @@ def _delete_initial( # pylint: disable=inconsistent-return-statements _params = case_insensitive_dict(kwargs.pop("params", {}) or {}) api_version: Literal["2022-04-01-preview"] = kwargs.pop( - "api_version", _params.pop("api-version", self._config.api_version) + "api_version", _params.pop("api-version", "2022-04-01-preview") ) cls: ClsType[None] = kwargs.pop("cls", None) @@ -724,7 +712,7 @@ def begin_delete( _params = case_insensitive_dict(kwargs.pop("params", {}) or {}) api_version: Literal["2022-04-01-preview"] = kwargs.pop( - "api_version", _params.pop("api-version", self._config.api_version) + "api_version", _params.pop("api-version", "2022-04-01-preview") ) cls: ClsType[None] = kwargs.pop("cls", None) polling: Union[bool, PollingMethod] = kwargs.pop("polling", True) diff --git a/sdk/databricks/azure-mgmt-databricks/azure/mgmt/databricks/operations/_private_link_resources_operations.py b/sdk/databricks/azure-mgmt-databricks/azure/mgmt/databricks/operations/_private_link_resources_operations.py index 94f68554d157..9000a0d8183d 100644 --- a/sdk/databricks/azure-mgmt-databricks/azure/mgmt/databricks/operations/_private_link_resources_operations.py +++ b/sdk/databricks/azure-mgmt-databricks/azure/mgmt/databricks/operations/_private_link_resources_operations.py @@ -8,7 +8,6 @@ # -------------------------------------------------------------------------- import sys from typing import Any, Callable, Dict, Iterable, Optional, TypeVar -import urllib.parse from azure.core.exceptions import ( ClientAuthenticationError, @@ -153,7 +152,7 @@ def list( _params = case_insensitive_dict(kwargs.pop("params", {}) or {}) api_version: Literal["2022-04-01-preview"] = kwargs.pop( - "api_version", _params.pop("api-version", self._config.api_version) + "api_version", _params.pop("api-version", "2022-04-01-preview") ) cls: ClsType[_models.PrivateLinkResourcesList] = kwargs.pop("cls", None) @@ -181,18 +180,7 @@ def prepare_request(next_link=None): request.url = self._client.format_url(request.url) else: - # make call to next link with the client's api-version - _parsed_next_link = urllib.parse.urlparse(next_link) - _next_request_params = case_insensitive_dict( - { - key: [urllib.parse.quote(v) for v in value] - for key, value in urllib.parse.parse_qs(_parsed_next_link.query).items() - } - ) - _next_request_params["api-version"] = self._config.api_version - request = HttpRequest( - "GET", urllib.parse.urljoin(next_link, _parsed_next_link.path), params=_next_request_params - ) + request = HttpRequest("GET", next_link) request = _convert_request(request) request.url = self._client.format_url(request.url) request.method = "GET" @@ -258,7 +246,7 @@ def get( _params = case_insensitive_dict(kwargs.pop("params", {}) or {}) api_version: Literal["2022-04-01-preview"] = kwargs.pop( - "api_version", _params.pop("api-version", self._config.api_version) + "api_version", _params.pop("api-version", "2022-04-01-preview") ) cls: ClsType[_models.GroupIdInformation] = kwargs.pop("cls", None) diff --git a/sdk/databricks/azure-mgmt-databricks/azure/mgmt/databricks/operations/_vnet_peering_operations.py b/sdk/databricks/azure-mgmt-databricks/azure/mgmt/databricks/operations/_vnet_peering_operations.py index 2d2ce4ddb521..85105a4e0ee6 100644 --- a/sdk/databricks/azure-mgmt-databricks/azure/mgmt/databricks/operations/_vnet_peering_operations.py +++ b/sdk/databricks/azure-mgmt-databricks/azure/mgmt/databricks/operations/_vnet_peering_operations.py @@ -8,7 +8,6 @@ # -------------------------------------------------------------------------- import sys from typing import Any, Callable, Dict, IO, Iterable, Optional, TypeVar, Union, cast, overload -import urllib.parse from azure.core.exceptions import ( ClientAuthenticationError, @@ -238,7 +237,7 @@ def get( _params = case_insensitive_dict(kwargs.pop("params", {}) or {}) api_version: Literal["2022-04-01-preview"] = kwargs.pop( - "api_version", _params.pop("api-version", self._config.api_version) + "api_version", _params.pop("api-version", "2022-04-01-preview") ) cls: ClsType[Optional[_models.VirtualNetworkPeering]] = kwargs.pop("cls", None) @@ -294,7 +293,7 @@ def _delete_initial( # pylint: disable=inconsistent-return-statements _params = case_insensitive_dict(kwargs.pop("params", {}) or {}) api_version: Literal["2022-04-01-preview"] = kwargs.pop( - "api_version", _params.pop("api-version", self._config.api_version) + "api_version", _params.pop("api-version", "2022-04-01-preview") ) cls: ClsType[None] = kwargs.pop("cls", None) @@ -358,7 +357,7 @@ def begin_delete( _params = case_insensitive_dict(kwargs.pop("params", {}) or {}) api_version: Literal["2022-04-01-preview"] = kwargs.pop( - "api_version", _params.pop("api-version", self._config.api_version) + "api_version", _params.pop("api-version", "2022-04-01-preview") ) cls: ClsType[None] = kwargs.pop("cls", None) polling: Union[bool, PollingMethod] = kwargs.pop("polling", True) @@ -420,7 +419,7 @@ def _create_or_update_initial( _params = case_insensitive_dict(kwargs.pop("params", {}) or {}) api_version: Literal["2022-04-01-preview"] = kwargs.pop( - "api_version", _params.pop("api-version", self._config.api_version) + "api_version", _params.pop("api-version", "2022-04-01-preview") ) content_type: Optional[str] = kwargs.pop("content_type", _headers.pop("Content-Type", None)) cls: ClsType[_models.VirtualNetworkPeering] = kwargs.pop("cls", None) @@ -597,7 +596,7 @@ def begin_create_or_update( _params = case_insensitive_dict(kwargs.pop("params", {}) or {}) api_version: Literal["2022-04-01-preview"] = kwargs.pop( - "api_version", _params.pop("api-version", self._config.api_version) + "api_version", _params.pop("api-version", "2022-04-01-preview") ) content_type: Optional[str] = kwargs.pop("content_type", _headers.pop("Content-Type", None)) cls: ClsType[_models.VirtualNetworkPeering] = kwargs.pop("cls", None) @@ -665,7 +664,7 @@ def list_by_workspace( _params = case_insensitive_dict(kwargs.pop("params", {}) or {}) api_version: Literal["2022-04-01-preview"] = kwargs.pop( - "api_version", _params.pop("api-version", self._config.api_version) + "api_version", _params.pop("api-version", "2022-04-01-preview") ) cls: ClsType[_models.VirtualNetworkPeeringList] = kwargs.pop("cls", None) @@ -693,18 +692,7 @@ def prepare_request(next_link=None): request.url = self._client.format_url(request.url) else: - # make call to next link with the client's api-version - _parsed_next_link = urllib.parse.urlparse(next_link) - _next_request_params = case_insensitive_dict( - { - key: [urllib.parse.quote(v) for v in value] - for key, value in urllib.parse.parse_qs(_parsed_next_link.query).items() - } - ) - _next_request_params["api-version"] = self._config.api_version - request = HttpRequest( - "GET", urllib.parse.urljoin(next_link, _parsed_next_link.path), params=_next_request_params - ) + request = HttpRequest("GET", next_link) request = _convert_request(request) request.url = self._client.format_url(request.url) request.method = "GET" diff --git a/sdk/databricks/azure-mgmt-databricks/azure/mgmt/databricks/operations/_workspaces_operations.py b/sdk/databricks/azure-mgmt-databricks/azure/mgmt/databricks/operations/_workspaces_operations.py index 3b328548cb50..2405052d6316 100644 --- a/sdk/databricks/azure-mgmt-databricks/azure/mgmt/databricks/operations/_workspaces_operations.py +++ b/sdk/databricks/azure-mgmt-databricks/azure/mgmt/databricks/operations/_workspaces_operations.py @@ -8,7 +8,6 @@ # -------------------------------------------------------------------------- import sys from typing import Any, Callable, Dict, IO, Iterable, Optional, TypeVar, Union, cast, overload -import urllib.parse from azure.core.exceptions import ( ClientAuthenticationError, @@ -292,7 +291,7 @@ def get(self, resource_group_name: str, workspace_name: str, **kwargs: Any) -> _ _params = case_insensitive_dict(kwargs.pop("params", {}) or {}) api_version: Literal["2022-04-01-preview"] = kwargs.pop( - "api_version", _params.pop("api-version", self._config.api_version) + "api_version", _params.pop("api-version", "2022-04-01-preview") ) cls: ClsType[_models.Workspace] = kwargs.pop("cls", None) @@ -345,7 +344,7 @@ def _delete_initial( # pylint: disable=inconsistent-return-statements _params = case_insensitive_dict(kwargs.pop("params", {}) or {}) api_version: Literal["2022-04-01-preview"] = kwargs.pop( - "api_version", _params.pop("api-version", self._config.api_version) + "api_version", _params.pop("api-version", "2022-04-01-preview") ) cls: ClsType[None] = kwargs.pop("cls", None) @@ -404,7 +403,7 @@ def begin_delete(self, resource_group_name: str, workspace_name: str, **kwargs: _params = case_insensitive_dict(kwargs.pop("params", {}) or {}) api_version: Literal["2022-04-01-preview"] = kwargs.pop( - "api_version", _params.pop("api-version", self._config.api_version) + "api_version", _params.pop("api-version", "2022-04-01-preview") ) cls: ClsType[None] = kwargs.pop("cls", None) polling: Union[bool, PollingMethod] = kwargs.pop("polling", True) @@ -460,7 +459,7 @@ def _create_or_update_initial( _params = case_insensitive_dict(kwargs.pop("params", {}) or {}) api_version: Literal["2022-04-01-preview"] = kwargs.pop( - "api_version", _params.pop("api-version", self._config.api_version) + "api_version", _params.pop("api-version", "2022-04-01-preview") ) content_type: Optional[str] = kwargs.pop("content_type", _headers.pop("Content-Type", None)) cls: ClsType[_models.Workspace] = kwargs.pop("cls", None) @@ -617,7 +616,7 @@ def begin_create_or_update( _params = case_insensitive_dict(kwargs.pop("params", {}) or {}) api_version: Literal["2022-04-01-preview"] = kwargs.pop( - "api_version", _params.pop("api-version", self._config.api_version) + "api_version", _params.pop("api-version", "2022-04-01-preview") ) content_type: Optional[str] = kwargs.pop("content_type", _headers.pop("Content-Type", None)) cls: ClsType[_models.Workspace] = kwargs.pop("cls", None) @@ -682,7 +681,7 @@ def _update_initial( _params = case_insensitive_dict(kwargs.pop("params", {}) or {}) api_version: Literal["2022-04-01-preview"] = kwargs.pop( - "api_version", _params.pop("api-version", self._config.api_version) + "api_version", _params.pop("api-version", "2022-04-01-preview") ) content_type: Optional[str] = kwargs.pop("content_type", _headers.pop("Content-Type", None)) cls: ClsType[Optional[_models.Workspace]] = kwargs.pop("cls", None) @@ -840,7 +839,7 @@ def begin_update( _params = case_insensitive_dict(kwargs.pop("params", {}) or {}) api_version: Literal["2022-04-01-preview"] = kwargs.pop( - "api_version", _params.pop("api-version", self._config.api_version) + "api_version", _params.pop("api-version", "2022-04-01-preview") ) content_type: Optional[str] = kwargs.pop("content_type", _headers.pop("Content-Type", None)) cls: ClsType[_models.Workspace] = kwargs.pop("cls", None) @@ -902,7 +901,7 @@ def list_by_resource_group(self, resource_group_name: str, **kwargs: Any) -> Ite _params = case_insensitive_dict(kwargs.pop("params", {}) or {}) api_version: Literal["2022-04-01-preview"] = kwargs.pop( - "api_version", _params.pop("api-version", self._config.api_version) + "api_version", _params.pop("api-version", "2022-04-01-preview") ) cls: ClsType[_models.WorkspaceListResult] = kwargs.pop("cls", None) @@ -929,18 +928,7 @@ def prepare_request(next_link=None): request.url = self._client.format_url(request.url) else: - # make call to next link with the client's api-version - _parsed_next_link = urllib.parse.urlparse(next_link) - _next_request_params = case_insensitive_dict( - { - key: [urllib.parse.quote(v) for v in value] - for key, value in urllib.parse.parse_qs(_parsed_next_link.query).items() - } - ) - _next_request_params["api-version"] = self._config.api_version - request = HttpRequest( - "GET", urllib.parse.urljoin(next_link, _parsed_next_link.path), params=_next_request_params - ) + request = HttpRequest("GET", next_link) request = _convert_request(request) request.url = self._client.format_url(request.url) request.method = "GET" @@ -987,7 +975,7 @@ def list_by_subscription(self, **kwargs: Any) -> Iterable["_models.Workspace"]: _params = case_insensitive_dict(kwargs.pop("params", {}) or {}) api_version: Literal["2022-04-01-preview"] = kwargs.pop( - "api_version", _params.pop("api-version", self._config.api_version) + "api_version", _params.pop("api-version", "2022-04-01-preview") ) cls: ClsType[_models.WorkspaceListResult] = kwargs.pop("cls", None) @@ -1013,18 +1001,7 @@ def prepare_request(next_link=None): request.url = self._client.format_url(request.url) else: - # make call to next link with the client's api-version - _parsed_next_link = urllib.parse.urlparse(next_link) - _next_request_params = case_insensitive_dict( - { - key: [urllib.parse.quote(v) for v in value] - for key, value in urllib.parse.parse_qs(_parsed_next_link.query).items() - } - ) - _next_request_params["api-version"] = self._config.api_version - request = HttpRequest( - "GET", urllib.parse.urljoin(next_link, _parsed_next_link.path), params=_next_request_params - ) + request = HttpRequest("GET", next_link) request = _convert_request(request) request.url = self._client.format_url(request.url) request.method = "GET" diff --git a/sdk/databricks/azure-mgmt-databricks/generated_samples/access_connector_create_or_update.py b/sdk/databricks/azure-mgmt-databricks/generated_samples/access_connector_create_or_update.py index 331a5bcb46d9..5cf1103b8a52 100644 --- a/sdk/databricks/azure-mgmt-databricks/generated_samples/access_connector_create_or_update.py +++ b/sdk/databricks/azure-mgmt-databricks/generated_samples/access_connector_create_or_update.py @@ -37,6 +37,6 @@ def main(): print(response) -# x-ms-original-file: specification/databricks/resource-manager/Microsoft.Databricks/preview/2022-04-01-preview/examples/AccessConnectorCreateOrUpdate.json +# x-ms-original-file: specification/databricks/resource-manager/Microsoft.Databricks/preview/2022-10-01-preview/examples/AccessConnectorCreateOrUpdate.json if __name__ == "__main__": main() diff --git a/sdk/databricks/azure-mgmt-databricks/generated_samples/access_connector_create_or_update_with_user_assigned.py b/sdk/databricks/azure-mgmt-databricks/generated_samples/access_connector_create_or_update_with_user_assigned.py new file mode 100644 index 000000000000..c4203271dadd --- /dev/null +++ b/sdk/databricks/azure-mgmt-databricks/generated_samples/access_connector_create_or_update_with_user_assigned.py @@ -0,0 +1,42 @@ +# 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. +# Code generated by Microsoft (R) AutoRest Code Generator. +# Changes may cause incorrect behavior and will be lost if the code is regenerated. +# -------------------------------------------------------------------------- + +from azure.identity import DefaultAzureCredential +from azure.mgmt.databricks import AzureDatabricksManagementClient + +""" +# PREREQUISITES + pip install azure-identity + pip install azure-mgmt-databricks +# USAGE + python access_connector_create_or_update_with_user_assigned.py + + Before run the sample, please set the values of the client ID, tenant ID and client secret + of the AAD application as environment variables: AZURE_CLIENT_ID, AZURE_TENANT_ID, + AZURE_CLIENT_SECRET. For more info about how to get the value, please see: + https://docs.microsoft.com/azure/active-directory/develop/howto-create-service-principal-portal +""" + + +def main(): + client = AzureDatabricksManagementClient( + credential=DefaultAzureCredential(), + subscription_id="subid", + ) + + response = client.access_connectors.begin_create_or_update( + resource_group_name="rg", + connector_name="myAccessConnector", + parameters={"location": "westus"}, + ).result() + print(response) + + +# x-ms-original-file: specification/databricks/resource-manager/Microsoft.Databricks/preview/2022-10-01-preview/examples/AccessConnectorCreateOrUpdateWithUserAssigned.json +if __name__ == "__main__": + main() diff --git a/sdk/databricks/azure-mgmt-databricks/generated_samples/access_connector_delete.py b/sdk/databricks/azure-mgmt-databricks/generated_samples/access_connector_delete.py index 9fcedfad32b5..a870dab4b620 100644 --- a/sdk/databricks/azure-mgmt-databricks/generated_samples/access_connector_delete.py +++ b/sdk/databricks/azure-mgmt-databricks/generated_samples/access_connector_delete.py @@ -36,6 +36,6 @@ def main(): print(response) -# x-ms-original-file: specification/databricks/resource-manager/Microsoft.Databricks/preview/2022-04-01-preview/examples/AccessConnectorDelete.json +# x-ms-original-file: specification/databricks/resource-manager/Microsoft.Databricks/preview/2022-10-01-preview/examples/AccessConnectorDelete.json if __name__ == "__main__": main() diff --git a/sdk/databricks/azure-mgmt-databricks/generated_samples/access_connector_get.py b/sdk/databricks/azure-mgmt-databricks/generated_samples/access_connector_get.py index 7debc57e1302..c32c7b78c872 100644 --- a/sdk/databricks/azure-mgmt-databricks/generated_samples/access_connector_get.py +++ b/sdk/databricks/azure-mgmt-databricks/generated_samples/access_connector_get.py @@ -36,6 +36,6 @@ def main(): print(response) -# x-ms-original-file: specification/databricks/resource-manager/Microsoft.Databricks/preview/2022-04-01-preview/examples/AccessConnectorGet.json +# x-ms-original-file: specification/databricks/resource-manager/Microsoft.Databricks/preview/2022-10-01-preview/examples/AccessConnectorGet.json if __name__ == "__main__": main() diff --git a/sdk/databricks/azure-mgmt-databricks/generated_samples/access_connector_patch_update.py b/sdk/databricks/azure-mgmt-databricks/generated_samples/access_connector_patch_update.py index c032d6ac38a8..0bd755150003 100644 --- a/sdk/databricks/azure-mgmt-databricks/generated_samples/access_connector_patch_update.py +++ b/sdk/databricks/azure-mgmt-databricks/generated_samples/access_connector_patch_update.py @@ -37,6 +37,6 @@ def main(): print(response) -# x-ms-original-file: specification/databricks/resource-manager/Microsoft.Databricks/preview/2022-04-01-preview/examples/AccessConnectorPatchUpdate.json +# x-ms-original-file: specification/databricks/resource-manager/Microsoft.Databricks/preview/2022-10-01-preview/examples/AccessConnectorPatchUpdate.json if __name__ == "__main__": main() diff --git a/sdk/databricks/azure-mgmt-databricks/generated_samples/access_connectors_list_by_resource_group.py b/sdk/databricks/azure-mgmt-databricks/generated_samples/access_connectors_list_by_resource_group.py index 597456f44593..69dfec9f5005 100644 --- a/sdk/databricks/azure-mgmt-databricks/generated_samples/access_connectors_list_by_resource_group.py +++ b/sdk/databricks/azure-mgmt-databricks/generated_samples/access_connectors_list_by_resource_group.py @@ -36,6 +36,6 @@ def main(): print(item) -# x-ms-original-file: specification/databricks/resource-manager/Microsoft.Databricks/preview/2022-04-01-preview/examples/AccessConnectorsListByResourceGroup.json +# x-ms-original-file: specification/databricks/resource-manager/Microsoft.Databricks/preview/2022-10-01-preview/examples/AccessConnectorsListByResourceGroup.json if __name__ == "__main__": main() diff --git a/sdk/databricks/azure-mgmt-databricks/generated_samples/access_connectors_list_by_subscription_id.py b/sdk/databricks/azure-mgmt-databricks/generated_samples/access_connectors_list_by_subscription_id.py index 302bfbdfa275..af6d370ac951 100644 --- a/sdk/databricks/azure-mgmt-databricks/generated_samples/access_connectors_list_by_subscription_id.py +++ b/sdk/databricks/azure-mgmt-databricks/generated_samples/access_connectors_list_by_subscription_id.py @@ -34,6 +34,6 @@ def main(): print(item) -# x-ms-original-file: specification/databricks/resource-manager/Microsoft.Databricks/preview/2022-04-01-preview/examples/AccessConnectorsListBySubscriptionId.json +# x-ms-original-file: specification/databricks/resource-manager/Microsoft.Databricks/preview/2022-10-01-preview/examples/AccessConnectorsListBySubscriptionId.json if __name__ == "__main__": main()