[SchemaRegistry] remove pinned azure-schemaregistry in dev reqs (#37631)

* fix verifytypes

* recordings update

* scrub api-version

* remove accept header from recordings

* remove type error message check b/c different messages

Author: swathipil

sdk/eventhub/azure-eventhub/samples/async_samples/send_and_receive_amqp_annotated_message_async.py

@@ -11,9 +11,10 @@
 
 import os
 import asyncio
+from azure.eventhub import TransportType
 from azure.eventhub.aio import EventHubProducerClient, EventHubConsumerClient
 from azure.eventhub.amqp import AmqpAnnotatedMessage, AmqpMessageBodyType
-from azure.identity.aio import DefaultAzureCredential
+from azure.identity.aio import AzureCliCredential
 
 FULLY_QUALIFIED_NAMESPACE = os.environ["EVENT_HUB_HOSTNAME"]
 EVENTHUB_NAME = os.environ['EVENT_HUB_NAME']
@@ -97,7 +98,8 @@ async def main():
     producer = EventHubProducerClient(
         fully_qualified_namespace=FULLY_QUALIFIED_NAMESPACE,
         eventhub_name=EVENTHUB_NAME,
-        credential=DefaultAzureCredential(),
+        credential=AzureCliCredential(),
+        transport_type=TransportType.AmqpOverWebsocket
     )
     async with producer:
         await send_data_message(producer)
@@ -107,9 +109,10 @@ async def main():
     # Receive
     consumer = EventHubConsumerClient(
         fully_qualified_namespace=FULLY_QUALIFIED_NAMESPACE,
-        credential=DefaultAzureCredential(),
+        credential=AzureCliCredential(),
         consumer_group='$Default',
         eventhub_name=EVENTHUB_NAME,
+        transport_type=TransportType.AmqpOverWebsocket
     )
     await receive_and_parse_message(consumer)
 

sdk/schemaregistry/azure-schemaregistry-avroencoder/assets.json

@@ -2,5 +2,5 @@
   "AssetsRepo": "Azure/azure-sdk-assets",
   "AssetsRepoPrefixPath": "python",
   "TagPrefix": "python/schemaregistry/azure-schemaregistry-avroencoder",
-  "Tag": "python/schemaregistry/azure-schemaregistry-avroencoder_50158ba496"
+  "Tag": "python/schemaregistry/azure-schemaregistry-avroencoder_0971c24bdc"
 }

sdk/schemaregistry/azure-schemaregistry-avroencoder/conftest.py

@@ -2,14 +2,19 @@
 from devtools_testutils import (
     test_proxy,
     add_general_regex_sanitizer,
+    add_remove_header_sanitizer,
     add_oauth_response_sanitizer,
     remove_batch_sanitizers,
 )
 
 # autouse=True will trigger this fixture on each pytest run, even if it's not explicitly used by a test method
 @pytest.fixture(scope="session", autouse=True)
 def add_sanitizers(test_proxy):
+    # Scrubbing api-version since latest and mindependency versions of azure-schemaregistry will not be the same.
+    add_general_regex_sanitizer(regex="(?<=api-version=)[0-9]{4}-[0-9]{2}", value="xxxx-xx")
     add_general_regex_sanitizer(regex="(?<=\\/\\/)[a-z-]+(?=\\.servicebus\\.windows\\.net)", value="fake_resource_avro")
+    # Accept is not used by the service. Removing from request headers so changes to Accept are not flagged as diffs.
+    add_remove_header_sanitizer(headers="Accept")
     add_oauth_response_sanitizer()
 
     # Remove the following sanitizers since certain fields are needed in tests and are non-sensitive:

sdk/schemaregistry/azure-schemaregistry-avroencoder/dev_requirements.txt

@@ -1,4 +1,4 @@
 -e ../../../tools/azure-sdk-tools
 -e ../../identity/azure-identity
 aiohttp>=3.0
-azure-schemaregistry<=1.2.0
+azure-schemaregistry

sdk/schemaregistry/azure-schemaregistry-avroencoder/tests/test_avro_encoder.py

@@ -275,17 +275,16 @@ def test_basic_sr_avro_encoder_with_request_options(self, **kwargs):
         schema_str = """{"namespace":"example.avro","type":"record","name":"User","fields":[{"name":"name","type":"string"},{"name":"favorite_number","type":["int","null"]},{"name":"favorite_color","type":["string","null"]}]}"""
 
         dict_content = {"name": u"Ben", "favorite_number": 7, "favorite_color": u"red"}
+        # if fake kwargs/incorrectly formatted request keyword passed in, should raise TypeError
         with pytest.raises(TypeError) as e:
-            encoded_message_content = sr_avro_encoder.encode(dict_content, schema=schema_str, request_options={"fake_kwarg": True})
-        assert 'request() got an unexpected keyword' in str(e.value)
+            encoded_message_content = sr_avro_encoder.encode(dict_content, schema=schema_str, request_options={"fake_kwarg": True, "files": frozenset({'a': False})})
         encoded_message_content = sr_avro_encoder.encode(dict_content, schema=schema_str)
         content_type = encoded_message_content["content_type"]
         encoded_content = encoded_message_content["content"]
 
         encoded_content_dict = {"content": encoded_content, "content_type": content_type}
         with pytest.raises(TypeError) as e:
-            decoded_content = sr_avro_encoder.decode(encoded_content_dict, request_options={"fake_kwarg": True})
-        assert 'request() got an unexpected keyword' in str(e.value)
+            decoded_content = sr_avro_encoder.decode(encoded_content_dict, request_options={"fake_kwarg": True, "files": (False)})
 
 
     ################################################################# 

sdk/schemaregistry/azure-schemaregistry-avroencoder/tests/test_avro_encoder_async.py

@@ -240,17 +240,16 @@ async def test_basic_sr_avro_encoder_with_request_options(self, **kwargs):
         schema_str = """{"namespace":"example.avro","type":"record","name":"User","fields":[{"name":"name","type":"string"},{"name":"favorite_number","type":["int","null"]},{"name":"favorite_color","type":["string","null"]}]}"""
 
         dict_content = {"name": u"Ben", "favorite_number": 7, "favorite_color": u"red"}
+        # if fake kwargs/incorrectly formatted request keyword passed in, should raise TypeError
         with pytest.raises(TypeError) as e:
-            encoded_message_content = await sr_avro_encoder.encode(dict_content, schema=schema_str, request_options={"fake_kwarg": True})
-        assert 'request() got an unexpected keyword' in str(e.value)
+            encoded_message_content = await sr_avro_encoder.encode(dict_content, schema=schema_str, request_options={"fake_kwarg": True, "files": (False)})
         encoded_message_content = await sr_avro_encoder.encode(dict_content, schema=schema_str)
         content_type = encoded_message_content["content_type"]
         encoded_content = encoded_message_content["content"]
 
         encoded_content_dict = {"content": encoded_content, "content_type": content_type}
         with pytest.raises(TypeError) as e:
-            decoded_content = await sr_avro_encoder.decode(encoded_content_dict, request_options={"fake_kwarg": True})
-        assert 'request() got an unexpected keyword' in str(e.value)
+            decoded_content = await sr_avro_encoder.decode(encoded_content_dict, request_options={"fake_kwarg": True, "files": (False)})
 
     ################################################################# 
     ######################### PARSE SCHEMAS #########################