Skip to content

Commit

Permalink
revert changes
Browse files Browse the repository at this point in the history
  • Loading branch information
iscai-msft committed Jun 6, 2024
1 parent d71c77b commit a3f8f22
Show file tree
Hide file tree
Showing 72 changed files with 498 additions and 578 deletions.
57 changes: 28 additions & 29 deletions .../AcceptanceTests/CustomPollerPager/custompollerpager/aio/operations/_paging_operations.py
View file
Original file line number Diff line number Diff line change
Expand Up @@ -7,7 +7,7 @@
# Changes may cause incorrect behavior and will be lost if the code is regenerated.
# --------------------------------------------------------------------------
import sys
from typing import Any, AsyncIterable, AsyncIterator, Callable, Dict, Literal, Optional, Type, TypeVar, Union, cast
from typing import Any, AsyncIterable, Callable, Dict, Literal, Optional, Type, TypeVar, Union, cast
import urllib.parse

from custompollerpagerdefinitions.aio import AsyncCustomPager, AsyncCustomPoller
Expand Down Expand Up @@ -135,7 +135,7 @@ def prepare_request(next_link=None):
return _request

async def extract_data(pipeline_response):
deserialized = self._deserialize("ProductResultValue", pipeline_response.http_response)
deserialized = self._deserialize("ProductResultValue", pipeline_response)
list_of_elem = deserialized.value
if cls:
list_of_elem = cls(list_of_elem) # type: ignore
Expand Down Expand Up @@ -208,7 +208,7 @@ def prepare_request(next_link=None):
return _request

async def extract_data(pipeline_response):
deserialized = self._deserialize("ProductResultValue", pipeline_response.http_response)
deserialized = self._deserialize("ProductResultValue", pipeline_response)
list_of_elem = deserialized.value
if cls:
list_of_elem = cls(list_of_elem) # type: ignore
Expand Down Expand Up @@ -281,7 +281,7 @@ def prepare_request(next_link=None):
return _request

async def extract_data(pipeline_response):
deserialized = self._deserialize("ProductResult", pipeline_response.http_response)
deserialized = self._deserialize("ProductResult", pipeline_response)
list_of_elem = deserialized.values
if cls:
list_of_elem = cls(list_of_elem) # type: ignore
Expand Down Expand Up @@ -354,7 +354,7 @@ def prepare_request(next_link=None):
return _request

async def extract_data(pipeline_response):
deserialized = self._deserialize("ProductResult", pipeline_response.http_response)
deserialized = self._deserialize("ProductResult", pipeline_response)
list_of_elem = deserialized.values
if cls:
list_of_elem = cls(list_of_elem) # type: ignore
Expand Down Expand Up @@ -436,7 +436,7 @@ def prepare_request(next_link=None):
return _request

async def extract_data(pipeline_response):
deserialized = self._deserialize("ProductResult", pipeline_response.http_response)
deserialized = self._deserialize("ProductResult", pipeline_response)
list_of_elem = deserialized.values
if cls:
list_of_elem = cls(list_of_elem) # type: ignore
Expand Down Expand Up @@ -510,7 +510,7 @@ def prepare_request(next_link=None):
return _request

async def extract_data(pipeline_response):
deserialized = self._deserialize("ProductResultValue", pipeline_response.http_response)
deserialized = self._deserialize("ProductResultValue", pipeline_response)
list_of_elem = deserialized.value
if cls:
list_of_elem = cls(list_of_elem) # type: ignore
Expand Down Expand Up @@ -601,7 +601,7 @@ def prepare_request(next_link=None):
return _request

async def extract_data(pipeline_response):
deserialized = self._deserialize("ProductResult", pipeline_response.http_response)
deserialized = self._deserialize("ProductResult", pipeline_response)
list_of_elem = deserialized.values
if cls:
list_of_elem = cls(list_of_elem) # type: ignore
Expand Down Expand Up @@ -675,7 +675,7 @@ def prepare_request(next_link=None):
return _request

async def extract_data(pipeline_response):
deserialized = self._deserialize("ProductResult", pipeline_response.http_response)
deserialized = self._deserialize("ProductResult", pipeline_response)
list_of_elem = deserialized.values
if cls:
list_of_elem = cls(list_of_elem) # type: ignore
Expand Down Expand Up @@ -753,7 +753,7 @@ def prepare_request(next_link=None):
return _request

async def extract_data(pipeline_response):
deserialized = self._deserialize("ProductResult", pipeline_response.http_response)
deserialized = self._deserialize("ProductResult", pipeline_response)
list_of_elem = deserialized.values
if cls:
list_of_elem = cls(list_of_elem) # type: ignore
Expand Down Expand Up @@ -832,7 +832,7 @@ def prepare_request(next_link=None):
return _request

async def extract_data(pipeline_response):
deserialized = self._deserialize("ProductResult", pipeline_response.http_response)
deserialized = self._deserialize("ProductResult", pipeline_response)
list_of_elem = deserialized.values
if cls:
list_of_elem = cls(list_of_elem) # type: ignore
Expand Down Expand Up @@ -923,7 +923,7 @@ def prepare_request(next_link=None):
return _request

async def extract_data(pipeline_response):
deserialized = self._deserialize("OdataProductResult", pipeline_response.http_response)
deserialized = self._deserialize("OdataProductResult", pipeline_response)
list_of_elem = deserialized.values
if cls:
list_of_elem = cls(list_of_elem) # type: ignore
Expand Down Expand Up @@ -1017,7 +1017,7 @@ def prepare_request(next_link=None):
return _request

async def extract_data(pipeline_response):
deserialized = self._deserialize("ProductResult", pipeline_response.http_response)
deserialized = self._deserialize("ProductResult", pipeline_response)
list_of_elem = deserialized.values
if cls:
list_of_elem = cls(list_of_elem) # type: ignore
Expand Down Expand Up @@ -1091,7 +1091,7 @@ def prepare_request(next_link=None):
return _request

async def extract_data(pipeline_response):
deserialized = self._deserialize("ProductResult", pipeline_response.http_response)
deserialized = self._deserialize("ProductResult", pipeline_response)
list_of_elem = deserialized.values
if cls:
list_of_elem = cls(list_of_elem) # type: ignore
Expand Down Expand Up @@ -1165,7 +1165,7 @@ def prepare_request(next_link=None):
return _request

async def extract_data(pipeline_response):
deserialized = self._deserialize("ProductResult", pipeline_response.http_response)
deserialized = self._deserialize("ProductResult", pipeline_response)
list_of_elem = deserialized.values
if cls:
list_of_elem = cls(list_of_elem) # type: ignore
Expand Down Expand Up @@ -1238,7 +1238,7 @@ def prepare_request(next_link=None):
return _request

async def extract_data(pipeline_response):
deserialized = self._deserialize("ProductResult", pipeline_response.http_response)
deserialized = self._deserialize("ProductResult", pipeline_response)
list_of_elem = deserialized.values
if cls:
list_of_elem = cls(list_of_elem) # type: ignore
Expand Down Expand Up @@ -1311,7 +1311,7 @@ def prepare_request(next_link=None):
return _request

async def extract_data(pipeline_response):
deserialized = self._deserialize("ProductResult", pipeline_response.http_response)
deserialized = self._deserialize("ProductResult", pipeline_response)
list_of_elem = deserialized.values
if cls:
list_of_elem = cls(list_of_elem) # type: ignore
Expand Down Expand Up @@ -1384,7 +1384,7 @@ def prepare_request(next_link=None):
return _request

async def extract_data(pipeline_response):
deserialized = self._deserialize("ProductResult", pipeline_response.http_response)
deserialized = self._deserialize("ProductResult", pipeline_response)
list_of_elem = deserialized.values
if cls:
list_of_elem = cls(list_of_elem) # type: ignore
Expand Down Expand Up @@ -1461,7 +1461,7 @@ def prepare_request(next_link=None):
return _request

async def extract_data(pipeline_response):
deserialized = self._deserialize("OdataProductResult", pipeline_response.http_response)
deserialized = self._deserialize("OdataProductResult", pipeline_response)
list_of_elem = deserialized.values
if cls:
list_of_elem = cls(list_of_elem) # type: ignore
Expand Down Expand Up @@ -1546,7 +1546,7 @@ def prepare_request(next_link=None):
return _request

async def extract_data(pipeline_response):
deserialized = self._deserialize("OdataProductResult", pipeline_response.http_response)
deserialized = self._deserialize("OdataProductResult", pipeline_response)
list_of_elem = deserialized.values
if cls:
list_of_elem = cls(list_of_elem) # type: ignore
Expand Down Expand Up @@ -1576,7 +1576,7 @@ async def _get_multiple_pages_lro_initial(
client_request_id: Optional[str] = None,
paging_get_multiple_pages_lro_options: Optional[_models.PagingGetMultiplePagesLroOptions] = None,
**kwargs: Any
) -> AsyncIterator[bytes]:
) -> _models.ProductResult:
error_map: MutableMapping[int, Type[HttpResponseError]] = {
401: ClientAuthenticationError,
404: ResourceNotFoundError,
Expand All @@ -1588,7 +1588,7 @@ async def _get_multiple_pages_lro_initial(
_headers = kwargs.pop("headers", {}) or {}
_params = kwargs.pop("params", {}) or {}

cls: ClsType[AsyncIterator[bytes]] = kwargs.pop("cls", None)
cls: ClsType[_models.ProductResult] = kwargs.pop("cls", None)

_maxresults = None
_timeout = None
Expand All @@ -1605,7 +1605,7 @@ async def _get_multiple_pages_lro_initial(
)
_request.url = self._client.format_url(_request.url)

_stream = True
_stream = False
pipeline_response: PipelineResponse = await self._client._pipeline.run( # pylint: disable=protected-access
_request, stream=_stream, **kwargs
)
Expand All @@ -1618,7 +1618,7 @@ async def _get_multiple_pages_lro_initial(
map_error(status_code=response.status_code, response=response, error_map=error_map)
raise HttpResponseError(response=response, error_format=ARMErrorFormat)

deserialized = response.stream_download(self._client._pipeline)
deserialized = self._deserialize("ProductResult", pipeline_response)

if cls:
return cls(pipeline_response, deserialized, {}) # type: ignore
Expand Down Expand Up @@ -1694,7 +1694,7 @@ def prepare_request(next_link=None):
return _request

async def extract_data(pipeline_response):
deserialized = self._deserialize("ProductResult", pipeline_response.http_response)
deserialized = self._deserialize("ProductResult", pipeline_response)
list_of_elem = deserialized.values
if cls:
list_of_elem = cls(list_of_elem) # type: ignore
Expand Down Expand Up @@ -1729,7 +1729,6 @@ async def get_next(next_link=None):
params=_params,
**kwargs
)
await raw_result.http_response.read() # type: ignore
kwargs.pop("error_map", None)

def get_long_running_output(pipeline_response):
Expand Down Expand Up @@ -1808,7 +1807,7 @@ def prepare_request(next_link=None):
return _request

async def extract_data(pipeline_response):
deserialized = self._deserialize("ProductResult", pipeline_response.http_response)
deserialized = self._deserialize("ProductResult", pipeline_response)
list_of_elem = deserialized.values
if cls:
list_of_elem = cls(list_of_elem) # type: ignore
Expand Down Expand Up @@ -1884,7 +1883,7 @@ def prepare_request(next_link=None):
return _request

async def extract_data(pipeline_response):
deserialized = self._deserialize("ProductResult", pipeline_response.http_response)
deserialized = self._deserialize("ProductResult", pipeline_response)
list_of_elem = deserialized.values
if cls:
list_of_elem = cls(list_of_elem) # type: ignore
Expand Down Expand Up @@ -1960,7 +1959,7 @@ def prepare_request(next_link=None):
return _request

async def extract_data(pipeline_response):
deserialized = self._deserialize("ProductResultValueWithXMSClientName", pipeline_response.http_response)
deserialized = self._deserialize("ProductResultValueWithXMSClientName", pipeline_response)
list_of_elem = deserialized.indexes
if cls:
list_of_elem = cls(list_of_elem) # type: ignore
Expand Down
Loading

0 comments on commit a3f8f22

Please sign in to comment.