summaryrefslogtreecommitdiff
path: root/test/testutil.py
diff options
context:
space:
mode:
authorJeff Widman <jeff@jeffwidman.com>2018-05-28 15:58:26 -0700
committerJeff Widman <jeff@jeffwidman.com>2018-05-28 16:30:07 -0700
commitc666b4e251757b827d52d62f9d4a18ab5e728897 (patch)
treeb74c5190a0fd74afffb5318d4bd34b59ae33e25c /test/testutil.py
parent81cda595b3ecf17737b4e4d86efa230db2e9bd31 (diff)
downloadkafka-python-dont-use-kafka.common-internally.tar.gz
Don't use `kafka.common` internallydont-use-kafka.common-internally
This finishes the split from `kafka.common` to `kafka.errors`/`kafka.structs`.
Diffstat (limited to 'test/testutil.py')
-rw-r--r--test/testutil.py10
1 files changed, 6 insertions, 4 deletions
diff --git a/test/testutil.py b/test/testutil.py
index 365e47f..a1383a0 100644
--- a/test/testutil.py
+++ b/test/testutil.py
@@ -11,10 +11,12 @@ import pytest
from . import unittest
from kafka import SimpleClient, create_message
-from kafka.errors import LeaderNotAvailableError, KafkaTimeoutError, InvalidTopicError
-from kafka.structs import OffsetRequestPayload, ProduceRequestPayload, \
- NotLeaderForPartitionError, UnknownTopicOrPartitionError, \
- FailedPayloadsError
+from kafka.errors import (
+ LeaderNotAvailableError, KafkaTimeoutError, InvalidTopicError,
+ NotLeaderForPartitionError, UnknownTopicOrPartitionError,
+ FailedPayloadsError
+)
+from kafka.structs import OffsetRequestPayload, ProduceRequestPayload
from test.fixtures import random_string, version_str_to_list, version as kafka_version #pylint: disable=wrong-import-order
def kafka_versions(*versions):