fix line length

nameko · Sep 21, 2023 · 6830d19 · 6830d19
1 parent e788961
commit 6830d19
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/nameko_grpc/connection.py b/nameko_grpc/connection.py
@@ -330,8 +330,8 @@ def send_data(self, stream_id):
         # When a stream is closed, a STREAM_END item or ERROR is placed in the queue.
         # If we never read from the stream again, these are not consumed, and the
         # stream is never exhausted which prevents a graceful termination.
-        # Because we return early if headers haven't been sent, we need to manually flush the queue
-        # (an operation that would otherwise occur during `stream.read`)
+        # Because we return early if headers haven't been sent, we need to manually
+        # flush the queue (an operation that would otherwise occur during `stream.read`)
         send_stream.flush_queue_to_buffer()
 
         if not send_stream.headers_sent: