[Queues] Migrate to devtools test framework

sdk/storage/azure-storage-queue/conftest.py

@@ -7,11 +7,8 @@
 # --------------------------------------------------------------------------
 
 import sys
-import pytest
-import platform
-
 
 # Ignore async tests for Python < 3.5
 collect_ignore_glob = []
-if sys.version_info < (3, 5) or platform.python_implementation() == 'PyPy':
+if sys.version_info < (3, 5):
     collect_ignore_glob.append("tests/*_async.py")

sdk/storage/azure-storage-queue/tests/asyncqueuetestcase.py

@@ -0,0 +1,29 @@
+# coding: utf-8
+# -------------------------------------------------------------------------
+# Copyright (c) Microsoft Corporation. All rights reserved.
+# Licensed under the MIT License. See License.txt in the project root for
+# license information.
+# --------------------------------------------------------------------------
+import asyncio
+import functools
+from queuetestcase import QueueTestCase
+
+LOGGING_FORMAT = '%(asctime)s %(name)-20s %(levelname)-5s %(message)s'
+
+class AsyncQueueTestCase(QueueTestCase):
+    @staticmethod
+    def await_prepared_test(test_fn):
+        """Synchronous wrapper for async test methods. Used to avoid making changes
+        upstream to AbstractPreparer (which doesn't await the functions it wraps)
+        """
+
+        @functools.wraps(test_fn)
+        def run(test_class_instance, *args, **kwargs):
+            resource_group = kwargs.get("resource_group")
+            location = kwargs.get("location")
+            storage_account = kwargs.get("storage_account")
+            storage_account_key = kwargs.get("storage_account_key")
+            loop = asyncio.get_event_loop()
+            return loop.run_until_complete(test_fn(test_class_instance, resource_group, location, storage_account, storage_account_key))
+
+        return run