mirror of https://github.com/celery/kombu.git
flakes
This commit is contained in:
parent
010aae8ccf
commit
69ef48dd41
|
@ -1,6 +1,6 @@
|
||||||
#!/usr/bin/env python
|
#!/usr/bin/env python
|
||||||
|
|
||||||
from kombu import Connection, Producer, Queue
|
from kombu import Connection, Queue
|
||||||
from kombu.mixins import ConsumerProducerMixin
|
from kombu.mixins import ConsumerProducerMixin
|
||||||
|
|
||||||
rpc_queue = Queue('rpc_queue')
|
rpc_queue = Queue('rpc_queue')
|
||||||
|
|
|
@ -7,7 +7,7 @@ import sys
|
||||||
from base64 import b64decode
|
from base64 import b64decode
|
||||||
|
|
||||||
from kombu.exceptions import ContentDisallowed, EncodeError, DecodeError
|
from kombu.exceptions import ContentDisallowed, EncodeError, DecodeError
|
||||||
from kombu.five import text_t, bytes_t, items
|
from kombu.five import text_t, bytes_t
|
||||||
from kombu.serialization import (
|
from kombu.serialization import (
|
||||||
registry, register, SerializerNotInstalled,
|
registry, register, SerializerNotInstalled,
|
||||||
raw_encode, register_yaml, register_msgpack,
|
raw_encode, register_yaml, register_msgpack,
|
||||||
|
|
Loading…
Reference in New Issue