Skip to content

Commit

Permalink
Fix long line
Browse files Browse the repository at this point in the history
  • Loading branch information
bitphage committed Apr 11, 2023
1 parent 8b1a16d commit 7b69257
Showing 1 changed file with 6 additions and 4 deletions.
10 changes: 6 additions & 4 deletions tests/test_conn.py
Original file line number Diff line number Diff line change
Expand Up @@ -249,11 +249,13 @@ async def test_close_disconnects_connection(self):

@run_until_complete
async def test_semi_broken_connection(self):
"""This testcase tries to replicate what happens on connection to semi-broken AWS MSK broker.
"""This testcase tries to replicate what happens on connection to semi-broken
AWS MSK broker.
Connection could be established, but then some timeout occurs, and connection is not being destroyed
properly, producing 'Unclosed AIOKafkaConnection' and calling loop exception handler, which could lead to
failing the whole app for example if we're running via aiorun with `stop_on_unhandled_errors=True`.
Connection could be established, but then some timeout occurs, and connection is
not being destroyed properly, producing 'Unclosed AIOKafkaConnection' and
calling loop exception handler, which could lead to failing the whole app for
example if we're running via aiorun with `stop_on_unhandled_errors=True`.
"""
host, port = self.kafka_host, self.kafka_port

Expand Down

0 comments on commit 7b69257

Please sign in to comment.