Removes unneeded class

Signed-off-by: Elena Kolevska <elena@kolevska.com>

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
+        return response

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()

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'