From b04615f6cdbfdaf3d5a04eb34edd496b9ee417f1 Mon Sep 17 00:00:00 2001 From: Elena Kolevska Date: Fri, 11 Oct 2024 19:05:33 +0100 Subject: [PATCH] Removes unneeded class Signed-off-by: Elena Kolevska --- dapr/aio/clients/grpc/interceptors.py | 3 ++- dapr/clients/grpc/subscription.py | 1 - dapr/common/pubsub/subscription.py | 6 ------ 3 files changed, 2 insertions(+), 8 deletions(-) diff --git a/dapr/aio/clients/grpc/interceptors.py b/dapr/aio/clients/grpc/interceptors.py index 346214dc..bf83cf56 100644 --- a/dapr/aio/clients/grpc/interceptors.py +++ b/dapr/aio/clients/grpc/interceptors.py @@ -50,6 +50,7 @@ def intercept_unary_unary(self, continuation, client_call_details, request): return continuation(client_call_details, request) + class DaprClientInterceptorAsync(UnaryUnaryClientInterceptor, StreamStreamClientInterceptor): """The class implements a UnaryUnaryClientInterceptor from grpc to add an interceptor to add additional headers to all calls as needed. @@ -135,4 +136,4 @@ async def intercept_stream_stream(self, continuation, client_call_details, reque new_call_details = await self._intercept_call(client_call_details) # Call continuation response = await continuation(new_call_details, request) - return response \ No newline at end of file + return response diff --git a/dapr/clients/grpc/subscription.py b/dapr/clients/grpc/subscription.py index a69df125..b5a87080 100644 --- a/dapr/clients/grpc/subscription.py +++ b/dapr/clients/grpc/subscription.py @@ -59,7 +59,6 @@ def outgoing_request_iterator(): except Exception as e: raise Exception(f'Error while initializing stream: {e}') - def reconnect_stream(self): self.close() DaprHealth.wait_until_ready() diff --git a/dapr/common/pubsub/subscription.py b/dapr/common/pubsub/subscription.py index 0f96ab6b..ad6f6f56 100644 --- a/dapr/common/pubsub/subscription.py +++ b/dapr/common/pubsub/subscription.py @@ -86,9 +86,3 @@ def _parse_data_content(self): class StreamInactiveError(Exception): pass - - -class PubSubEventStatus: - SUCCESS = 'success' - RETRY = 'retry' - DROP = 'drop'