Skip to content
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
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
Original file line number Diff line number Diff line change
Expand Up @@ -202,6 +202,7 @@ def get_value_to_append(self, query):
return return_value + '\n'

def add_resource_signature(self, account_name, account_key, path, user_delegation_key=None):
# pylint: disable = no-member
if path[0] != '/':
path = '/' + path

Expand Down
5 changes: 1 addition & 4 deletions sdk/storage/azure-storage-queue/conftest.py
Original file line number Diff line number Diff line change
Expand Up @@ -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")
25 changes: 25 additions & 0 deletions sdk/storage/azure-storage-queue/tests/asyncqueuetestcase.py
Original file line number Diff line number Diff line change
@@ -0,0 +1,25 @@
# 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):
loop = asyncio.get_event_loop()
return loop.run_until_complete(test_fn(test_class_instance, **kwargs))

return run
56 changes: 0 additions & 56 deletions sdk/storage/azure-storage-queue/tests/queue_settings_fake.py

This file was deleted.

Loading