Skip to content
This repository has been archived by the owner on Mar 24, 2021. It is now read-only.

Commit

Permalink
switch base class import
Browse files Browse the repository at this point in the history
  • Loading branch information
emmettbutler committed Apr 24, 2015
1 parent b082b82 commit 910a227
Showing 1 changed file with 3 additions and 3 deletions.
6 changes: 3 additions & 3 deletions pykafka/topic.py
Original file line number Diff line number Diff line change
Expand Up @@ -16,12 +16,12 @@
See the License for the specific language governing permissions and
limitations under the License.
"""
__all__ = ["Topic", "base.BaseTopic"]
__all__ = ["Topic", "BaseTopic"]
import logging
import weakref
from collections import defaultdict

import base
from base import BaseTopic
from .balancedconsumer import BalancedConsumer
from .common import OffsetType
from .partition import Partition
Expand All @@ -33,7 +33,7 @@
logger = logging.getLogger()


class Topic(base.BaseTopic):
class Topic(BaseTopic):
def __init__(self, cluster, topic_metadata):
"""Create the Topic from metadata.
Expand Down

0 comments on commit 910a227

Please sign in to comment.