diff --git a/sprockets/mixins/avro_publisher/__init__.py b/sprockets/mixins/avro_publisher/__init__.py index 2561e79..3dcb232 100644 --- a/sprockets/mixins/avro_publisher/__init__.py +++ b/sprockets/mixins/avro_publisher/__init__.py @@ -14,9 +14,10 @@ import io import json import logging -from sprockets.mixins import amqp, http import fastavro +from sprockets.mixins import amqp, http + __version__ = '3.0.0' LOGGER = logging.getLogger(__name__) diff --git a/tests/tests.py b/tests/tests.py index a0ecb99..37488b5 100644 --- a/tests/tests.py +++ b/tests/tests.py @@ -1,29 +1,29 @@ -import json import io -import os -import sys +import json import logging +import os import random +import sys import uuid -from tornado import concurrent, locks, testing, web import fastavro from pika import spec +from tornado import concurrent, locks, testing, web from sprockets.mixins import amqp, avro_publisher LOGGER = logging.getLogger(__name__) -MESSAGE_TYPE = "example.avro.Test" +MESSAGE_TYPE = 'example.avro.Test' AVRO_SCHEMA = { - "namespace": "example.avro", - "type": "record", - "name": "User", - "fields": [ - {"name": "name", "type": "string"}, - {"name": "favorite_number", "type": ["int", "null"]}, - {"name": "favorite_color", "type": ["string", "null"]}]} + 'namespace': 'example.avro', + 'type': 'record', + 'name': 'User', + 'fields': [ + {'name': 'name', 'type': 'string'}, + {'name': 'favorite_number', 'type': ['int', 'null']}, + {'name': 'favorite_color', 'type': ['string', 'null']}]} def deserialize(value):