Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Live pipeline issues #13526

Merged
merged 4 commits into from
Sep 2, 2020
Merged

Live pipeline issues #13526

Show file tree
Hide file tree
Changes from 3 commits
Commits
Show all changes
4 commits
Select commit Hold shift + click to select a range
20e06e7
changes to the tests that reflects the new serialization of EntityPro…
seankane-msft Sep 2, 2020
6fc0ddf
re-generated code, fixed a couple test methods, solved the media type…
seankane-msft Sep 2, 2020
949a883
re-record for merge issues
seankane-msft Sep 2, 2020
edaafab
updating a recording that slipped through
seankane-msft Sep 2, 2020
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
2 changes: 1 addition & 1 deletion sdk/tables/azure-data-tables/azure/data/tables/_generated/aio/__init__.py
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -6,5 +6,5 @@
# Changes may cause incorrect behavior and will be lost if the code is regenerated.
# --------------------------------------------------------------------------

from ._azure_table_async import AzureTable
from ._azure_table import AzureTable
__all__ = ['AzureTable']
10 changes: 5 additions & 5 deletions ...bles/_generated/aio/_azure_table_async.py → ...ata/tables/_generated/aio/_azure_table.py
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -11,19 +11,19 @@
from azure.core import AsyncPipelineClient
from msrest import Deserializer, Serializer

from ._configuration_async import AzureTableConfiguration
from .operations_async import TableOperations
from .operations_async import ServiceOperations
from ._configuration import AzureTableConfiguration
from .operations import TableOperations
from .operations import ServiceOperations
from .. import models


class AzureTable(object):
"""AzureTable.
:ivar table: TableOperations operations
:vartype table: azure.data.tables.aio.operations_async.TableOperations
:vartype table: azure.data.tables.aio.operations.TableOperations
:ivar service: ServiceOperations operations
:vartype service: azure.data.tables.aio.operations_async.ServiceOperations
:vartype service: azure.data.tables.aio.operations.ServiceOperations
:param url: The URL of the service account or table that is the target of the desired operation.
:type url: str
"""
Expand Down
0 ...es/_generated/aio/_configuration_async.py → ...a/tables/_generated/aio/_configuration.py
View file
Open in desktop
File renamed without changes.
4 changes: 2 additions & 2 deletions ...enerated/aio/operations_async/__init__.py → ...les/_generated/aio/operations/__init__.py
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -6,8 +6,8 @@
# Changes may cause incorrect behavior and will be lost if the code is regenerated.
# --------------------------------------------------------------------------

from ._table_operations_async import TableOperations
from ._service_operations_async import ServiceOperations
from ._table_operations import TableOperations
from ._service_operations import ServiceOperations

__all__ = [
'TableOperations',
Expand Down
9 changes: 6 additions & 3 deletions ...ations_async/_service_operations_async.py → ...ted/aio/operations/_service_operations.py
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -67,6 +67,7 @@ async def set_properties(
restype = "service"
comp = "properties"
content_type = kwargs.pop("content_type", "application/xml")
accept = "application/xml"

# Construct URL
url = self.set_properties.metadata['url'] # type: ignore
Expand All @@ -88,12 +89,12 @@ async def set_properties(
if request_id_parameter is not None:
header_parameters['x-ms-client-request-id'] = self._serialize.header("request_id_parameter", request_id_parameter, 'str')
header_parameters['Content-Type'] = self._serialize.header("content_type", content_type, 'str')
header_parameters['Accept'] = self._serialize.header("accept", accept, 'str')

body_content_kwargs = {} # type: Dict[str, Any]
body_content = self._serialize.body(table_service_properties, 'TableServiceProperties', is_xml=True)
body_content_kwargs['content'] = body_content
request = self._client.put(url, query_parameters, header_parameters, **body_content_kwargs)

pipeline_response = await self._client._pipeline.run(request, stream=False, **kwargs)
response = pipeline_response.http_response

Expand Down Expand Up @@ -136,6 +137,7 @@ async def get_properties(
error_map.update(kwargs.pop('error_map', {}))
restype = "service"
comp = "properties"
accept = "application/xml"

# Construct URL
url = self.get_properties.metadata['url'] # type: ignore
Expand All @@ -156,7 +158,7 @@ async def get_properties(
header_parameters['x-ms-version'] = self._serialize.header("self._config.version", self._config.version, 'str')
if request_id_parameter is not None:
header_parameters['x-ms-client-request-id'] = self._serialize.header("request_id_parameter", request_id_parameter, 'str')
header_parameters['Accept'] = 'application/xml'
header_parameters['Accept'] = self._serialize.header("accept", accept, 'str')

request = self._client.get(url, query_parameters, header_parameters)
pipeline_response = await self._client._pipeline.run(request, stream=False, **kwargs)
Expand Down Expand Up @@ -204,6 +206,7 @@ async def get_statistics(
error_map.update(kwargs.pop('error_map', {}))
restype = "service"
comp = "stats"
accept = "application/xml"

# Construct URL
url = self.get_statistics.metadata['url'] # type: ignore
Expand All @@ -224,7 +227,7 @@ async def get_statistics(
header_parameters['x-ms-version'] = self._serialize.header("self._config.version", self._config.version, 'str')
if request_id_parameter is not None:
header_parameters['x-ms-client-request-id'] = self._serialize.header("request_id_parameter", request_id_parameter, 'str')
header_parameters['Accept'] = 'application/xml'
header_parameters['Accept'] = self._serialize.header("accept", accept, 'str')

request = self._client.get(url, query_parameters, header_parameters)
pipeline_response = await self._client._pipeline.run(request, stream=False, **kwargs)
Expand Down
33 changes: 22 additions & 11 deletions ...erations_async/_table_operations_async.py → ...rated/aio/operations/_table_operations.py
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -74,6 +74,7 @@ async def query(
_select = query_options.select
_filter = query_options.filter
data_service_version = "3.0"
accept = "application/json;odata=minimalmetadata"

# Construct URL
url = self.query.metadata['url'] # type: ignore
Expand Down Expand Up @@ -101,7 +102,7 @@ async def query(
if request_id_parameter is not None:
header_parameters['x-ms-client-request-id'] = self._serialize.header("request_id_parameter", request_id_parameter, 'str')
header_parameters['DataServiceVersion'] = self._serialize.header("data_service_version", data_service_version, 'str')
header_parameters['Accept'] = 'application/json;odata=minimalmetadata'
header_parameters['Accept'] = self._serialize.header("accept", accept, 'str')

request = self._client.get(url, query_parameters, header_parameters)
pipeline_response = await self._client._pipeline.run(request, stream=False, **kwargs)
Expand Down Expand Up @@ -160,6 +161,7 @@ async def create(
_format = query_options.format
data_service_version = "3.0"
content_type = kwargs.pop("content_type", "application/json;odata=nometadata")
accept = "application/json;odata=minimalmetadata"

# Construct URL
url = self.create.metadata['url'] # type: ignore
Expand All @@ -182,13 +184,12 @@ async def create(
if response_preference is not None:
header_parameters['Prefer'] = self._serialize.header("response_preference", response_preference, 'str')
header_parameters['Content-Type'] = self._serialize.header("content_type", content_type, 'str')
header_parameters['Accept'] = 'application/json;odata=minimalmetadata'
header_parameters['Accept'] = self._serialize.header("accept", accept, 'str')

body_content_kwargs = {} # type: Dict[str, Any]
body_content = self._serialize.body(table_properties, 'TableProperties')
body_content_kwargs['content'] = body_content
request = self._client.post(url, query_parameters, header_parameters, **body_content_kwargs)

pipeline_response = await self._client._pipeline.run(request, stream=False, **kwargs)
response = pipeline_response.http_response

Expand Down Expand Up @@ -241,6 +242,7 @@ async def delete(
cls = kwargs.pop('cls', None) # type: ClsType[None]
error_map = {404: ResourceNotFoundError, 409: ResourceExistsError}
error_map.update(kwargs.pop('error_map', {}))
accept = "application/json"

# Construct URL
url = self.delete.metadata['url'] # type: ignore
Expand All @@ -258,6 +260,7 @@ async def delete(
header_parameters['x-ms-version'] = self._serialize.header("self._config.version", self._config.version, 'str')
if request_id_parameter is not None:
header_parameters['x-ms-client-request-id'] = self._serialize.header("request_id_parameter", request_id_parameter, 'str')
header_parameters['Accept'] = self._serialize.header("accept", accept, 'str')

request = self._client.delete(url, query_parameters, header_parameters)
pipeline_response = await self._client._pipeline.run(request, stream=False, **kwargs)
Expand Down Expand Up @@ -323,6 +326,7 @@ async def query_entities(
_select = query_options.select
_filter = query_options.filter
data_service_version = "3.0"
accept = "application/json;odata=minimalmetadata"

# Construct URL
url = self.query_entities.metadata['url'] # type: ignore
Expand Down Expand Up @@ -355,7 +359,7 @@ async def query_entities(
if request_id_parameter is not None:
header_parameters['x-ms-client-request-id'] = self._serialize.header("request_id_parameter", request_id_parameter, 'str')
header_parameters['DataServiceVersion'] = self._serialize.header("data_service_version", data_service_version, 'str')
header_parameters['Accept'] = 'application/json;odata=minimalmetadata'
header_parameters['Accept'] = self._serialize.header("accept", accept, 'str')

request = self._client.get(url, query_parameters, header_parameters)
pipeline_response = await self._client._pipeline.run(request, stream=False, **kwargs)
Expand Down Expand Up @@ -423,6 +427,7 @@ async def query_entities_with_partition_and_row_key(
_select = query_options.select
_filter = query_options.filter
data_service_version = "3.0"
accept = "application/json;odata=minimalmetadata"

# Construct URL
url = self.query_entities_with_partition_and_row_key.metadata['url'] # type: ignore
Expand Down Expand Up @@ -451,7 +456,7 @@ async def query_entities_with_partition_and_row_key(
if request_id_parameter is not None:
header_parameters['x-ms-client-request-id'] = self._serialize.header("request_id_parameter", request_id_parameter, 'str')
header_parameters['DataServiceVersion'] = self._serialize.header("data_service_version", data_service_version, 'str')
header_parameters['Accept'] = 'application/json;odata=minimalmetadata'
header_parameters['Accept'] = self._serialize.header("accept", accept, 'str')

request = self._client.get(url, query_parameters, header_parameters)
pipeline_response = await self._client._pipeline.run(request, stream=False, **kwargs)
Expand Down Expand Up @@ -526,6 +531,7 @@ async def update_entity(
_format = query_options.format
data_service_version = "3.0"
content_type = kwargs.pop("content_type", "application/json")
accept = "application/json"

# Construct URL
url = self.update_entity.metadata['url'] # type: ignore
Expand Down Expand Up @@ -553,6 +559,7 @@ async def update_entity(
if if_match is not None:
header_parameters['If-Match'] = self._serialize.header("if_match", if_match, 'str')
header_parameters['Content-Type'] = self._serialize.header("content_type", content_type, 'str')
header_parameters['Accept'] = self._serialize.header("accept", accept, 'str')

body_content_kwargs = {} # type: Dict[str, Any]
if table_entity_properties is not None:
Expand All @@ -561,7 +568,6 @@ async def update_entity(
body_content = None
body_content_kwargs['content'] = body_content
request = self._client.put(url, query_parameters, header_parameters, **body_content_kwargs)

pipeline_response = await self._client._pipeline.run(request, stream=False, **kwargs)
response = pipeline_response.http_response

Expand Down Expand Up @@ -630,6 +636,7 @@ async def merge_entity(
_format = query_options.format
data_service_version = "3.0"
content_type = kwargs.pop("content_type", "application/json")
accept = "application/json"

# Construct URL
url = self.merge_entity.metadata['url'] # type: ignore
Expand Down Expand Up @@ -657,6 +664,7 @@ async def merge_entity(
if if_match is not None:
header_parameters['If-Match'] = self._serialize.header("if_match", if_match, 'str')
header_parameters['Content-Type'] = self._serialize.header("content_type", content_type, 'str')
header_parameters['Accept'] = self._serialize.header("accept", accept, 'str')

body_content_kwargs = {} # type: Dict[str, Any]
if table_entity_properties is not None:
Expand All @@ -665,7 +673,6 @@ async def merge_entity(
body_content = None
body_content_kwargs['content'] = body_content
request = self._client.patch(url, query_parameters, header_parameters, **body_content_kwargs)

pipeline_response = await self._client._pipeline.run(request, stream=False, **kwargs)
response = pipeline_response.http_response

Expand Down Expand Up @@ -729,6 +736,7 @@ async def delete_entity(
if query_options is not None:
_format = query_options.format
data_service_version = "3.0"
accept = "application/json;odata=minimalmetadata"

# Construct URL
url = self.delete_entity.metadata['url'] # type: ignore
Expand All @@ -754,6 +762,7 @@ async def delete_entity(
header_parameters['x-ms-client-request-id'] = self._serialize.header("request_id_parameter", request_id_parameter, 'str')
header_parameters['DataServiceVersion'] = self._serialize.header("data_service_version", data_service_version, 'str')
header_parameters['If-Match'] = self._serialize.header("if_match", if_match, 'str')
header_parameters['Accept'] = self._serialize.header("accept", accept, 'str')

request = self._client.delete(url, query_parameters, header_parameters)
pipeline_response = await self._client._pipeline.run(request, stream=False, **kwargs)
Expand Down Expand Up @@ -815,6 +824,7 @@ async def insert_entity(
_format = query_options.format
data_service_version = "3.0"
content_type = kwargs.pop("content_type", "application/json;odata=nometadata")
accept = "application/json;odata=minimalmetadata"

# Construct URL
url = self.insert_entity.metadata['url'] # type: ignore
Expand All @@ -840,7 +850,7 @@ async def insert_entity(
if response_preference is not None:
header_parameters['Prefer'] = self._serialize.header("response_preference", response_preference, 'str')
header_parameters['Content-Type'] = self._serialize.header("content_type", content_type, 'str')
header_parameters['Accept'] = 'application/json;odata=minimalmetadata'
header_parameters['Accept'] = self._serialize.header("accept", accept, 'str')

body_content_kwargs = {} # type: Dict[str, Any]
if table_entity_properties is not None:
Expand All @@ -849,7 +859,6 @@ async def insert_entity(
body_content = None
body_content_kwargs['content'] = body_content
request = self._client.post(url, query_parameters, header_parameters, **body_content_kwargs)

pipeline_response = await self._client._pipeline.run(request, stream=False, **kwargs)
response = pipeline_response.http_response

Expand Down Expand Up @@ -911,6 +920,7 @@ async def get_access_policy(
error_map = {404: ResourceNotFoundError, 409: ResourceExistsError}
error_map.update(kwargs.pop('error_map', {}))
comp = "acl"
accept = "application/xml"

# Construct URL
url = self.get_access_policy.metadata['url'] # type: ignore
Expand All @@ -931,7 +941,7 @@ async def get_access_policy(
header_parameters['x-ms-version'] = self._serialize.header("self._config.version", self._config.version, 'str')
if request_id_parameter is not None:
header_parameters['x-ms-client-request-id'] = self._serialize.header("request_id_parameter", request_id_parameter, 'str')
header_parameters['Accept'] = 'application/xml'
header_parameters['Accept'] = self._serialize.header("accept", accept, 'str')

request = self._client.get(url, query_parameters, header_parameters)
pipeline_response = await self._client._pipeline.run(request, stream=False, **kwargs)
Expand Down Expand Up @@ -984,6 +994,7 @@ async def set_access_policy(
error_map.update(kwargs.pop('error_map', {}))
comp = "acl"
content_type = kwargs.pop("content_type", "application/xml")
accept = "application/xml"

# Construct URL
url = self.set_access_policy.metadata['url'] # type: ignore
Expand All @@ -1005,6 +1016,7 @@ async def set_access_policy(
if request_id_parameter is not None:
header_parameters['x-ms-client-request-id'] = self._serialize.header("request_id_parameter", request_id_parameter, 'str')
header_parameters['Content-Type'] = self._serialize.header("content_type", content_type, 'str')
header_parameters['Accept'] = self._serialize.header("accept", accept, 'str')

body_content_kwargs = {} # type: Dict[str, Any]
serialization_ctxt = {'xml': {'name': 'SignedIdentifiers', 'wrapped': True, 'itemsName': 'SignedIdentifier'}}
Expand All @@ -1014,7 +1026,6 @@ async def set_access_policy(
body_content = None
body_content_kwargs['content'] = body_content
request = self._client.put(url, query_parameters, header_parameters, **body_content_kwargs)

pipeline_response = await self._client._pipeline.run(request, stream=False, **kwargs)
response = pipeline_response.http_response

Expand Down
9 changes: 6 additions & 3 deletions sdk/tables/azure-data-tables/azure/data/tables/_generated/operations/_service_operations.py
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -72,6 +72,7 @@ def set_properties(
restype = "service"
comp = "properties"
content_type = kwargs.pop("content_type", "application/xml")
accept = "application/xml"

# Construct URL
url = self.set_properties.metadata['url'] # type: ignore
Expand All @@ -93,12 +94,12 @@ def set_properties(
if request_id_parameter is not None:
header_parameters['x-ms-client-request-id'] = self._serialize.header("request_id_parameter", request_id_parameter, 'str')
header_parameters['Content-Type'] = self._serialize.header("content_type", content_type, 'str')
header_parameters['Accept'] = self._serialize.header("accept", accept, 'str')

body_content_kwargs = {} # type: Dict[str, Any]
body_content = self._serialize.body(table_service_properties, 'TableServiceProperties', is_xml=True)
body_content_kwargs['content'] = body_content
request = self._client.put(url, query_parameters, header_parameters, **body_content_kwargs)

pipeline_response = self._client._pipeline.run(request, stream=False, **kwargs)
response = pipeline_response.http_response

Expand Down Expand Up @@ -142,6 +143,7 @@ def get_properties(
error_map.update(kwargs.pop('error_map', {}))
restype = "service"
comp = "properties"
accept = "application/xml"

# Construct URL
url = self.get_properties.metadata['url'] # type: ignore
Expand All @@ -162,7 +164,7 @@ def get_properties(
header_parameters['x-ms-version'] = self._serialize.header("self._config.version", self._config.version, 'str')
if request_id_parameter is not None:
header_parameters['x-ms-client-request-id'] = self._serialize.header("request_id_parameter", request_id_parameter, 'str')
header_parameters['Accept'] = 'application/xml'
header_parameters['Accept'] = self._serialize.header("accept", accept, 'str')

request = self._client.get(url, query_parameters, header_parameters)
pipeline_response = self._client._pipeline.run(request, stream=False, **kwargs)
Expand Down Expand Up @@ -211,6 +213,7 @@ def get_statistics(
error_map.update(kwargs.pop('error_map', {}))
restype = "service"
comp = "stats"
accept = "application/xml"

# Construct URL
url = self.get_statistics.metadata['url'] # type: ignore
Expand All @@ -231,7 +234,7 @@ def get_statistics(
header_parameters['x-ms-version'] = self._serialize.header("self._config.version", self._config.version, 'str')
if request_id_parameter is not None:
header_parameters['x-ms-client-request-id'] = self._serialize.header("request_id_parameter", request_id_parameter, 'str')
header_parameters['Accept'] = 'application/xml'
header_parameters['Accept'] = self._serialize.header("accept", accept, 'str')

request = self._client.get(url, query_parameters, header_parameters)
pipeline_response = self._client._pipeline.run(request, stream=False, **kwargs)
Expand Down
Loading