Live pipeline issues (Azure#13526)

* changes to the tests that reflects the new serialization of EntityProperties, failing on acl payloads and sas signed identifiers

* re-generated code, fixed a couple test methods, solved the media type issue for AccessPolicies, re-recorded tests because of changes in EntityProperty

* updating a recording that slipped through

sdk/tables/azure-data-tables/azure/data/tables/_generated/aio/__init__.py

@@ -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']

sdk/tables/azure-data-tables/azure/data/tables/_generated/aio/_azure_table_async.py → sdk/tables/azure-data-tables/azure/data/tables/_generated/aio/_azure_table.py

@@ -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
     """

sdk/tables/azure-data-tables/azure/data/tables/_generated/aio/operations_async/__init__.py → sdk/tables/azure-data-tables/azure/data/tables/_generated/aio/operations/__init__.py

@@ -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',

sdk/tables/azure-data-tables/azure/data/tables/_generated/aio/operations_async/_service_operations_async.py → sdk/tables/azure-data-tables/azure/data/tables/_generated/aio/operations/_service_operations.py

@@ -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
@@ -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
 
@@ -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
@@ -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)
@@ -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
@@ -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)

sdk/tables/azure-data-tables/azure/data/tables/_generated/aio/operations_async/_table_operations_async.py → sdk/tables/azure-data-tables/azure/data/tables/_generated/aio/operations/_table_operations.py

@@ -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
@@ -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)
@@ -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
@@ -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
 
@@ -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
@@ -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)
@@ -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
@@ -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)
@@ -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
@@ -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)
@@ -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
@@ -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:
@@ -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
 
@@ -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
@@ -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:
@@ -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
 
@@ -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
@@ -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)
@@ -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
@@ -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:
@@ -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
 
@@ -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
@@ -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)
@@ -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
@@ -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'}}
@@ -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
 

sdk/tables/azure-data-tables/azure/data/tables/_generated/operations/_service_operations.py

@@ -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
@@ -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
 
@@ -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
@@ -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)
@@ -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
@@ -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)