diff options
Diffstat (limited to 'test/testutil.py')
| -rw-r--r-- | test/testutil.py | 10 |
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): |