From 9456b5354987fea5a90c3e3b36659f45e2828b7c Mon Sep 17 00:00:00 2001 From: Elena Kolevska Date: Mon, 21 Oct 2024 14:16:08 +0100 Subject: [PATCH] lint Signed-off-by: Elena Kolevska --- dapr/clients/grpc/subscription.py | 2 -- examples/pubsub-streaming/subscriber-handler.py | 1 + 2 files changed, 1 insertion(+), 2 deletions(-) diff --git a/dapr/clients/grpc/subscription.py b/dapr/clients/grpc/subscription.py index 931be8e1..80db4fbf 100644 --- 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 index 4409fa5a..3a963fd2 100644 --- 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