Skip to content

Commit 6776c12

Browse files
committed
Implemented SanicAmqpExtension mixin
1 parent 048b834 commit 6776c12

File tree

2 files changed

+8
-1
lines changed

2 files changed

+8
-1
lines changed

sage_utils/amqp/__init__.py

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,4 +1,5 @@
11
from sage_utils.amqp.base import AmqpWorker # NOQA
2-
from sage_utils.amqp.extension import AmqpExtension # NOQA
32
from sage_utils.amqp.clients import RpcAmqpClient # NOQA
3+
from sage_utils.amqp.extension import AmqpExtension # NOQA
4+
from sage_utils.amqp.mixins import SanicAmqpExtensionMixin # NOQA
45
from sage_utils.amqp.workers import BaseRegisterWorker # NOQA

sage_utils/amqp/mixins.py

Lines changed: 6 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,6 @@
1+
2+
3+
class SanicAmqpExtensionMixin(object):
4+
"""Mixin class for compatibility with sanic-amqp-extension package."""
5+
async def deinit(self, *args, **kwargs):
6+
await self.free_resources(*args, **kwargs)

0 commit comments

Comments
 (0)