Marmelator/pyinfra
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases 36 Wiki Activity

Merge branch 'master' of ssh://git.iqser.com:2222/rr/pyinfra into sonarscan_refac

Browse Source
This commit is contained in:
Matthias Bisping 2022-04-21 14:38:58 +02:00
commit 4009de5d37
3 changed files with 2 additions and 14 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
pyinfra/queue/queue_manager/pika_queue_manager.py
View File

@ -72,6 +72,7 @@ class PikaQueueManager(QueueManager):
self.connection = pika.BlockingConnection(parameters=connection_params) self.connection = pika.BlockingConnection(parameters=connection_params)
self.channel = self.connection.channel() self.channel = self.connection.channel()
self.channel.basic_qos(prefetch_count=1)
if not dead_letter_queue: if not dead_letter_queue:
dead_letter_queue = CONFIG.rabbitmq.queues.dead_letter dead_letter_queue = CONFIG.rabbitmq.queues.dead_letter

4
pyinfra/storage/adapters/azure.py
View File

@ -1,10 +1,8 @@
from itertools import repeat
import logging import logging
from functools import wraps from itertools import repeat
from operator import attrgetter from operator import attrgetter
from azure.storage.blob import ContainerClient, BlobServiceClient from azure.storage.blob import ContainerClient, BlobServiceClient
from retry import retry
from pyinfra.storage.adapters.adapter import StorageAdapter from pyinfra.storage.adapters.adapter import StorageAdapter

11
pyinfra/test/unit_tests/storage_test.py
View File

@ -2,9 +2,6 @@ import logging
import pytest import pytest
from pyinfra.storage.storage import Storage
from pyinfra.storage.storages import get_azure_storage, get_s3_storage
logger = logging.getLogger(__name__) logger = logging.getLogger(__name__)
logger.setLevel(logging.DEBUG) logger.setLevel(logging.DEBUG)
@ -46,11 +43,3 @@ class TestStorage:
storage.put_object(bucket_name, "file2", b"content 2") storage.put_object(bucket_name, "file2", b"content 2")
full_names_received = storage.get_all_object_names(bucket_name) full_names_received = storage.get_all_object_names(bucket_name)
assert {(bucket_name, "file1"), (bucket_name, "file2")} == {*full_names_received} assert {(bucket_name, "file1"), (bucket_name, "file2")} == {*full_names_received}
def test_get_azure_storage_yields_storage():
assert isinstance(get_azure_storage(), Storage)
def test_get_s3_storage_yields_storage():
assert isinstance(get_s3_storage(), Storage)