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

set prefetch count to 1; removed obsolete imports

Browse Source
This commit is contained in:
Matthias Bisping 2022-04-21 13:03:48 +02:00
parent c933f66a4b
commit 51a459cbf0
2 changed files with 2 additions and 3 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