Skip to content

Commit

Permalink
Docstring
Browse files Browse the repository at this point in the history
  • Loading branch information
tonyo committed Aug 17, 2020
1 parent 6ff8171 commit 68b2fd1
Showing 1 changed file with 3 additions and 0 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -71,6 +71,9 @@ def inner(project=default_project):


def _wait_for_topic(admin_client, topic_name, timeout=5):
"""
Wait until the given topic is in operable state
"""
from confluent_kafka import KafkaError

start = time.time()
Expand Down

0 comments on commit 68b2fd1

Please sign in to comment.