lint

Signed-off-by: Elena Kolevska <[email protected]>
dapr · Oct 21, 2024 · 9456b53 · 9456b53
1 parent 2ab9a77
commit 9456b53
Show file tree

Hide file tree

Showing 2 changed files with 1 addition and 2 deletions.
diff --git a/dapr/clients/grpc/subscription.py b/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)

diff --git a/examples/pubsub-streaming/subscriber-handler.py b/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