summaryrefslogtreecommitdiff
path: root/kafka/coordinator/assignors/range.py
diff options
context:
space:
mode:
authorKevin Tindall <kevinkjt2000@users.noreply.github.com>2018-02-06 14:10:45 -0600
committerDana Powers <dana.powers@gmail.com>2018-02-06 12:10:45 -0800
commit9ae0e590b5ea93a9c07d71b55b593e0fcc973bc6 (patch)
tree7baee93ef095c3694a9ddbc50809b2a681ef56f8 /kafka/coordinator/assignors/range.py
parentc0df771cf51bc27f2dd5d5af333666f4074e68c8 (diff)
downloadkafka-python-9ae0e590b5ea93a9c07d71b55b593e0fcc973bc6.tar.gz
use absolute imports everywhere (#1362)
Diffstat (limited to 'kafka/coordinator/assignors/range.py')
-rw-r--r--kafka/coordinator/assignors/range.py4
1 files changed, 2 insertions, 2 deletions
diff --git a/kafka/coordinator/assignors/range.py b/kafka/coordinator/assignors/range.py
index cbf411e..c232d9e 100644
--- a/kafka/coordinator/assignors/range.py
+++ b/kafka/coordinator/assignors/range.py
@@ -5,8 +5,8 @@ import logging
from kafka.vendor import six
-from .abstract import AbstractPartitionAssignor
-from ..protocol import ConsumerProtocolMemberMetadata, ConsumerProtocolMemberAssignment
+from kafka.coordinator.assignors.abstract import AbstractPartitionAssignor
+from kafka.coordinator.protocol import ConsumerProtocolMemberMetadata, ConsumerProtocolMemberAssignment
log = logging.getLogger(__name__)