Skip to content

Commit 289c84e

Browse files
author
SDKAuto
committed
CodeGen from PR 25029 in Azure/azure-rest-api-specs
Merge 3ecb4e4398aeccb1e438357af5d930df591c5a1c into ab1a77260290c9c2978c6e64732aa043a5026160
1 parent c302659 commit 289c84e

File tree

914 files changed

+25055
-22530
lines changed

Some content is hidden

Large Commits have some content hidden by default. Use the searchbox below for content that may be hidden.

914 files changed

+25055
-22530
lines changed

‎sdk/sql/azure-mgmt-sql/_meta.json‎

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -1,11 +1,11 @@
11
{
2-
"commit": "d03c1964cb76ffd6884d10a1871bbe779a2f68ef",
2+
"commit": "b16044eb796a6b31caf40a108caf956db59dd1d9",
33
"repository_url": "https://github.com/Azure/azure-rest-api-specs",
4-
"autorest": "3.9.2",
4+
"autorest": "3.9.6",
55
"use": [
66
"@autorest/python@6.6.0",
7-
"@autorest/modelerfour@4.24.3"
7+
"@autorest/modelerfour@4.26.2"
88
],
9-
"autorest_command": "autorest specification/sql/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 --tag=package-composite-v5 --use=@autorest/python@6.6.0 --use=@autorest/modelerfour@4.24.3 --version=3.9.2 --version-tolerant=False",
9+
"autorest_command": "autorest specification/sql/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.6.0 --use=@autorest/modelerfour@4.26.2 --version=3.9.6 --version-tolerant=False",
1010
"readme": "specification/sql/resource-manager/readme.md"
1111
}

‎sdk/sql/azure-mgmt-sql/azure/mgmt/sql/_configuration.py‎

Lines changed: 6 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -29,17 +29,23 @@ class SqlManagementClientConfiguration(Configuration): # pylint: disable=too-ma
2929
:type credential: ~azure.core.credentials.TokenCredential
3030
:param subscription_id: The subscription ID that identifies an Azure subscription. Required.
3131
:type subscription_id: str
32+
:keyword api_version: Api Version. Default value is "2022-11-01-preview". Note that overriding
33+
this default value may result in unsupported behavior.
34+
:paramtype api_version: str
3235
"""
3336

3437
def __init__(self, credential: "TokenCredential", subscription_id: str, **kwargs: Any) -> None:
3538
super(SqlManagementClientConfiguration, self).__init__(**kwargs)
39+
api_version: str = kwargs.pop("api_version", "2022-11-01-preview")
40+
3641
if credential is None:
3742
raise ValueError("Parameter 'credential' must not be None.")
3843
if subscription_id is None:
3944
raise ValueError("Parameter 'subscription_id' must not be None.")
4045

4146
self.credential = credential
4247
self.subscription_id = subscription_id
48+
self.api_version = api_version
4349
self.credential_scopes = kwargs.pop("credential_scopes", ["https://management.azure.com/.default"])
4450
kwargs.setdefault("sdk_moniker", "mgmt-sql/{}".format(VERSION))
4551
self._configure(**kwargs)

‎sdk/sql/azure-mgmt-sql/azure/mgmt/sql/_sql_management_client.py‎

Lines changed: 359 additions & 374 deletions
Large diffs are not rendered by default.

‎sdk/sql/azure-mgmt-sql/azure/mgmt/sql/_version.py‎

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -6,4 +6,4 @@
66
# Changes may cause incorrect behavior and will be lost if the code is regenerated.
77
# --------------------------------------------------------------------------
88

9-
VERSION = "4.0.0b11"
9+
VERSION = "0.9.0"

‎sdk/sql/azure-mgmt-sql/azure/mgmt/sql/aio/_configuration.py‎

Lines changed: 6 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -29,17 +29,23 @@ class SqlManagementClientConfiguration(Configuration): # pylint: disable=too-ma
2929
:type credential: ~azure.core.credentials_async.AsyncTokenCredential
3030
:param subscription_id: The subscription ID that identifies an Azure subscription. Required.
3131
:type subscription_id: str
32+
:keyword api_version: Api Version. Default value is "2022-11-01-preview". Note that overriding
33+
this default value may result in unsupported behavior.
34+
:paramtype api_version: str
3235
"""
3336

3437
def __init__(self, credential: "AsyncTokenCredential", subscription_id: str, **kwargs: Any) -> None:
3538
super(SqlManagementClientConfiguration, self).__init__(**kwargs)
39+
api_version: str = kwargs.pop("api_version", "2022-11-01-preview")
40+
3641
if credential is None:
3742
raise ValueError("Parameter 'credential' must not be None.")
3843
if subscription_id is None:
3944
raise ValueError("Parameter 'subscription_id' must not be None.")
4045

4146
self.credential = credential
4247
self.subscription_id = subscription_id
48+
self.api_version = api_version
4349
self.credential_scopes = kwargs.pop("credential_scopes", ["https://management.azure.com/.default"])
4450
kwargs.setdefault("sdk_moniker", "mgmt-sql/{}".format(VERSION))
4551
self._configure(**kwargs)

‎sdk/sql/azure-mgmt-sql/azure/mgmt/sql/aio/_sql_management_client.py‎

Lines changed: 375 additions & 390 deletions
Large diffs are not rendered by default.

‎sdk/sql/azure-mgmt-sql/azure/mgmt/sql/aio/operations/__init__.py‎

Lines changed: 156 additions & 162 deletions
Large diffs are not rendered by default.

‎sdk/sql/azure-mgmt-sql/azure/mgmt/sql/aio/operations/_backup_short_term_retention_policies_operations.py‎

Lines changed: 102 additions & 90 deletions
Original file line numberDiff line numberDiff line change
@@ -8,6 +8,7 @@
88
# --------------------------------------------------------------------------
99
from io import IOBase
1010
from typing import Any, AsyncIterable, Callable, Dict, IO, Optional, TypeVar, Union, cast, overload
11+
import urllib.parse
1112

1213
from azure.core.async_paging import AsyncItemPaged, AsyncList
1314
from azure.core.exceptions import (
@@ -60,6 +61,102 @@ def __init__(self, *args, **kwargs) -> None:
6061
self._serialize = input_args.pop(0) if input_args else kwargs.pop("serializer")
6162
self._deserialize = input_args.pop(0) if input_args else kwargs.pop("deserializer")
6263

64+
@distributed_trace
65+
def list_by_database(
66+
self, resource_group_name: str, server_name: str, database_name: str, **kwargs: Any
67+
) -> AsyncIterable["_models.BackupShortTermRetentionPolicy"]:
68+
"""Gets a database's short term retention policy.
69+
70+
:param resource_group_name: The name of the resource group that contains the resource. You can
71+
obtain this value from the Azure Resource Manager API or the portal. Required.
72+
:type resource_group_name: str
73+
:param server_name: The name of the server. Required.
74+
:type server_name: str
75+
:param database_name: The name of the database. Required.
76+
:type database_name: str
77+
:keyword callable cls: A custom type or function that will be passed the direct response
78+
:return: An iterator like instance of either BackupShortTermRetentionPolicy or the result of
79+
cls(response)
80+
:rtype:
81+
~azure.core.async_paging.AsyncItemPaged[~azure.mgmt.sql.models.BackupShortTermRetentionPolicy]
82+
:raises ~azure.core.exceptions.HttpResponseError:
83+
"""
84+
_headers = kwargs.pop("headers", {}) or {}
85+
_params = case_insensitive_dict(kwargs.pop("params", {}) or {})
86+
87+
api_version: str = kwargs.pop("api_version", _params.pop("api-version", self._config.api_version))
88+
cls: ClsType[_models.BackupShortTermRetentionPolicyListResult] = kwargs.pop("cls", None)
89+
90+
error_map = {
91+
401: ClientAuthenticationError,
92+
404: ResourceNotFoundError,
93+
409: ResourceExistsError,
94+
304: ResourceNotModifiedError,
95+
}
96+
error_map.update(kwargs.pop("error_map", {}) or {})
97+
98+
def prepare_request(next_link=None):
99+
if not next_link:
100+
101+
request = build_list_by_database_request(
102+
resource_group_name=resource_group_name,
103+
server_name=server_name,
104+
database_name=database_name,
105+
subscription_id=self._config.subscription_id,
106+
api_version=api_version,
107+
template_url=self.list_by_database.metadata["url"],
108+
headers=_headers,
109+
params=_params,
110+
)
111+
request = _convert_request(request)
112+
request.url = self._client.format_url(request.url)
113+
114+
else:
115+
# make call to next link with the client's api-version
116+
_parsed_next_link = urllib.parse.urlparse(next_link)
117+
_next_request_params = case_insensitive_dict(
118+
{
119+
key: [urllib.parse.quote(v) for v in value]
120+
for key, value in urllib.parse.parse_qs(_parsed_next_link.query).items()
121+
}
122+
)
123+
_next_request_params["api-version"] = self._config.api_version
124+
request = HttpRequest(
125+
"GET", urllib.parse.urljoin(next_link, _parsed_next_link.path), params=_next_request_params
126+
)
127+
request = _convert_request(request)
128+
request.url = self._client.format_url(request.url)
129+
request.method = "GET"
130+
return request
131+
132+
async def extract_data(pipeline_response):
133+
deserialized = self._deserialize("BackupShortTermRetentionPolicyListResult", pipeline_response)
134+
list_of_elem = deserialized.value
135+
if cls:
136+
list_of_elem = cls(list_of_elem) # type: ignore
137+
return deserialized.next_link or None, AsyncList(list_of_elem)
138+
139+
async def get_next(next_link=None):
140+
request = prepare_request(next_link)
141+
142+
_stream = False
143+
pipeline_response: PipelineResponse = await self._client._pipeline.run( # pylint: disable=protected-access
144+
request, stream=_stream, **kwargs
145+
)
146+
response = pipeline_response.http_response
147+
148+
if response.status_code not in [200]:
149+
map_error(status_code=response.status_code, response=response, error_map=error_map)
150+
raise HttpResponseError(response=response, error_format=ARMErrorFormat)
151+
152+
return pipeline_response
153+
154+
return AsyncItemPaged(get_next, extract_data)
155+
156+
list_by_database.metadata = {
157+
"url": "/subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/Microsoft.Sql/servers/{serverName}/databases/{databaseName}/backupShortTermRetentionPolicies"
158+
}
159+
63160
@distributed_trace_async
64161
async def get(
65162
self,
@@ -96,7 +193,7 @@ async def get(
96193
_headers = kwargs.pop("headers", {}) or {}
97194
_params = case_insensitive_dict(kwargs.pop("params", {}) or {})
98195

99-
api_version: str = kwargs.pop("api_version", _params.pop("api-version", "2021-02-01-preview"))
196+
api_version: str = kwargs.pop("api_version", _params.pop("api-version", self._config.api_version))
100197
cls: ClsType[_models.BackupShortTermRetentionPolicy] = kwargs.pop("cls", None)
101198

102199
request = build_get_request(
@@ -155,7 +252,7 @@ async def _create_or_update_initial(
155252
_headers = case_insensitive_dict(kwargs.pop("headers", {}) or {})
156253
_params = case_insensitive_dict(kwargs.pop("params", {}) or {})
157254

158-
api_version: str = kwargs.pop("api_version", _params.pop("api-version", "2021-02-01-preview"))
255+
api_version: str = kwargs.pop("api_version", _params.pop("api-version", self._config.api_version))
159256
content_type: Optional[str] = kwargs.pop("content_type", _headers.pop("Content-Type", None))
160257
cls: ClsType[Optional[_models.BackupShortTermRetentionPolicy]] = kwargs.pop("cls", None)
161258

@@ -338,7 +435,7 @@ async def begin_create_or_update(
338435
_headers = case_insensitive_dict(kwargs.pop("headers", {}) or {})
339436
_params = case_insensitive_dict(kwargs.pop("params", {}) or {})
340437

341-
api_version: str = kwargs.pop("api_version", _params.pop("api-version", "2021-02-01-preview"))
438+
api_version: str = kwargs.pop("api_version", _params.pop("api-version", self._config.api_version))
342439
content_type: Optional[str] = kwargs.pop("content_type", _headers.pop("Content-Type", None))
343440
cls: ClsType[_models.BackupShortTermRetentionPolicy] = kwargs.pop("cls", None)
344441
polling: Union[bool, AsyncPollingMethod] = kwargs.pop("polling", True)
@@ -405,7 +502,7 @@ async def _update_initial(
405502
_headers = case_insensitive_dict(kwargs.pop("headers", {}) or {})
406503
_params = case_insensitive_dict(kwargs.pop("params", {}) or {})
407504

408-
api_version: str = kwargs.pop("api_version", _params.pop("api-version", "2021-02-01-preview"))
505+
api_version: str = kwargs.pop("api_version", _params.pop("api-version", self._config.api_version))
409506
content_type: Optional[str] = kwargs.pop("content_type", _headers.pop("Content-Type", None))
410507
cls: ClsType[Optional[_models.BackupShortTermRetentionPolicy]] = kwargs.pop("cls", None)
411508

@@ -588,7 +685,7 @@ async def begin_update(
588685
_headers = case_insensitive_dict(kwargs.pop("headers", {}) or {})
589686
_params = case_insensitive_dict(kwargs.pop("params", {}) or {})
590687

591-
api_version: str = kwargs.pop("api_version", _params.pop("api-version", "2021-02-01-preview"))
688+
api_version: str = kwargs.pop("api_version", _params.pop("api-version", self._config.api_version))
592689
content_type: Optional[str] = kwargs.pop("content_type", _headers.pop("Content-Type", None))
593690
cls: ClsType[_models.BackupShortTermRetentionPolicy] = kwargs.pop("cls", None)
594691
polling: Union[bool, AsyncPollingMethod] = kwargs.pop("polling", True)
@@ -634,88 +731,3 @@ def get_long_running_output(pipeline_response):
634731
begin_update.metadata = {
635732
"url": "/subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/Microsoft.Sql/servers/{serverName}/databases/{databaseName}/backupShortTermRetentionPolicies/{policyName}"
636733
}
637-
638-
@distributed_trace
639-
def list_by_database(
640-
self, resource_group_name: str, server_name: str, database_name: str, **kwargs: Any
641-
) -> AsyncIterable["_models.BackupShortTermRetentionPolicy"]:
642-
"""Gets a database's short term retention policy.
643-
644-
:param resource_group_name: The name of the resource group that contains the resource. You can
645-
obtain this value from the Azure Resource Manager API or the portal. Required.
646-
:type resource_group_name: str
647-
:param server_name: The name of the server. Required.
648-
:type server_name: str
649-
:param database_name: The name of the database. Required.
650-
:type database_name: str
651-
:keyword callable cls: A custom type or function that will be passed the direct response
652-
:return: An iterator like instance of either BackupShortTermRetentionPolicy or the result of
653-
cls(response)
654-
:rtype:
655-
~azure.core.async_paging.AsyncItemPaged[~azure.mgmt.sql.models.BackupShortTermRetentionPolicy]
656-
:raises ~azure.core.exceptions.HttpResponseError:
657-
"""
658-
_headers = kwargs.pop("headers", {}) or {}
659-
_params = case_insensitive_dict(kwargs.pop("params", {}) or {})
660-
661-
api_version: str = kwargs.pop("api_version", _params.pop("api-version", "2021-02-01-preview"))
662-
cls: ClsType[_models.BackupShortTermRetentionPolicyListResult] = kwargs.pop("cls", None)
663-
664-
error_map = {
665-
401: ClientAuthenticationError,
666-
404: ResourceNotFoundError,
667-
409: ResourceExistsError,
668-
304: ResourceNotModifiedError,
669-
}
670-
error_map.update(kwargs.pop("error_map", {}) or {})
671-
672-
def prepare_request(next_link=None):
673-
if not next_link:
674-
675-
request = build_list_by_database_request(
676-
resource_group_name=resource_group_name,
677-
server_name=server_name,
678-
database_name=database_name,
679-
subscription_id=self._config.subscription_id,
680-
api_version=api_version,
681-
template_url=self.list_by_database.metadata["url"],
682-
headers=_headers,
683-
params=_params,
684-
)
685-
request = _convert_request(request)
686-
request.url = self._client.format_url(request.url)
687-
688-
else:
689-
request = HttpRequest("GET", next_link)
690-
request = _convert_request(request)
691-
request.url = self._client.format_url(request.url)
692-
request.method = "GET"
693-
return request
694-
695-
async def extract_data(pipeline_response):
696-
deserialized = self._deserialize("BackupShortTermRetentionPolicyListResult", pipeline_response)
697-
list_of_elem = deserialized.value
698-
if cls:
699-
list_of_elem = cls(list_of_elem) # type: ignore
700-
return deserialized.next_link or None, AsyncList(list_of_elem)
701-
702-
async def get_next(next_link=None):
703-
request = prepare_request(next_link)
704-
705-
_stream = False
706-
pipeline_response: PipelineResponse = await self._client._pipeline.run( # pylint: disable=protected-access
707-
request, stream=_stream, **kwargs
708-
)
709-
response = pipeline_response.http_response
710-
711-
if response.status_code not in [200]:
712-
map_error(status_code=response.status_code, response=response, error_map=error_map)
713-
raise HttpResponseError(response=response, error_format=ARMErrorFormat)
714-
715-
return pipeline_response
716-
717-
return AsyncItemPaged(get_next, extract_data)
718-
719-
list_by_database.metadata = {
720-
"url": "/subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/Microsoft.Sql/servers/{serverName}/databases/{databaseName}/backupShortTermRetentionPolicies"
721-
}

‎sdk/sql/azure-mgmt-sql/azure/mgmt/sql/aio/operations/_capabilities_operations.py‎

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -79,7 +79,7 @@ async def list_by_location(
7979
_headers = kwargs.pop("headers", {}) or {}
8080
_params = case_insensitive_dict(kwargs.pop("params", {}) or {})
8181

82-
api_version: str = kwargs.pop("api_version", _params.pop("api-version", "2020-11-01-preview"))
82+
api_version: str = kwargs.pop("api_version", _params.pop("api-version", self._config.api_version))
8383
cls: ClsType[_models.LocationCapabilities] = kwargs.pop("cls", None)
8484

8585
request = build_list_by_location_request(

0 commit comments

Comments
 (0)