lint

Signed-off-by: Elena Kolevska <[email protected]>

Author: elena-kolevska

dapr/clients/grpc/subscription.py

@@ -74,7 +74,6 @@ def next_message(self):
         if not self._is_stream_active() or self._stream is None:
             raise StreamInactiveError('Stream is not active')
 
-
         try:
             # Read the next message from the stream directly
             message = next(self._stream)
@@ -94,7 +93,6 @@ def next_message(self):
         except Exception as e:
             raise Exception(f'Error while fetching message: {e}')
 
-
     def respond(self, message, status):
         try:
             status = appcallback_v1.TopicEventResponse(status=status.value)

examples/pubsub-streaming/subscriber-handler.py

@@ -13,6 +13,7 @@
 topic_name = args.topic
 dlq_topic_name = topic_name + '_DEAD'
 
+
 def process_message(message):
     # Process the message here
     global counter