Skip to content

Commit

Permalink
fixed black issue
Browse files Browse the repository at this point in the history
  • Loading branch information
MrTrustworthy committed Jul 3, 2019
1 parent f66e9d2 commit 8a639f4
Showing 1 changed file with 2 additions and 2 deletions.
4 changes: 2 additions & 2 deletions tests/conftest.py
Expand Up @@ -122,7 +122,7 @@ def consumergroup_controller(cluster: Cluster):

@pytest.fixture()
def consumergroup_instance(
partly_read_consumer_group: str, consumergroup_controller: ConsumerGroupController
partly_read_consumer_group: str, consumergroup_controller: ConsumerGroupController
):
yield consumergroup_controller.get_consumergroup(partly_read_consumer_group)

Expand Down Expand Up @@ -162,7 +162,7 @@ def filled_topic(producer, topic_object):

@pytest.fixture()
def partly_read_consumer_group(
consumer: confluent_kafka.Consumer, filled_topic, consumer_group
consumer: confluent_kafka.Consumer, filled_topic, consumer_group
):
for i in range(5):
msg = consumer.consume(timeout=10)[0]
Expand Down

0 comments on commit 8a639f4

Please sign in to comment.