diff --git a/asyncworker/easyqueue/connection.py b/asyncworker/easyqueue/connection.py index 828d9392..fe945194 100644 --- a/asyncworker/easyqueue/connection.py +++ b/asyncworker/easyqueue/connection.py @@ -7,6 +7,7 @@ from aioamqp.channel import Channel from aioamqp.exceptions import AioamqpException from aioamqp.protocol import OPEN + from asyncworker.conf import settings OnErrorCallback = Union[ diff --git a/asyncworker/easyqueue/queue.py b/asyncworker/easyqueue/queue.py index c9b4cd3e..a6e91a4f 100644 --- a/asyncworker/easyqueue/queue.py +++ b/asyncworker/easyqueue/queue.py @@ -22,6 +22,7 @@ from aioamqp.channel import Channel from aioamqp.envelope import Envelope from aioamqp.properties import Properties + from asyncworker.conf import settings from asyncworker.easyqueue.connection import AMQPConnection from asyncworker.easyqueue.exceptions import UndecodableMessageException diff --git a/tests/easyqueue/base.py b/tests/easyqueue/base.py index 48892443..ce1d401e 100644 --- a/tests/easyqueue/base.py +++ b/tests/easyqueue/base.py @@ -1,6 +1,7 @@ from unittest.mock import AsyncMock, patch import aioamqp + from asyncworker.easyqueue.queue import JsonQueue, QueueConsumerDelegate