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'