add grpc helpers, lint

Signed-off-by: Filinto Duran <[email protected]>

Author: filintod

dapr/actor/__init__.py

@@ -20,7 +20,6 @@
 from dapr.actor.runtime.remindable import Remindable
 from dapr.actor.runtime.runtime import ActorRuntime
 
-
 __all__ = [
     'ActorInterface',
     'ActorProxy',

dapr/actor/client/proxy.py

@@ -21,8 +21,8 @@
 from dapr.actor.runtime._type_utils import get_dispatchable_attrs_from_interface
 from dapr.clients import DaprActorClientBase, DaprActorHttpClient
 from dapr.clients.retry import RetryPolicy
-from dapr.serializers import Serializer, DefaultJSONSerializer
 from dapr.conf import settings
+from dapr.serializers import DefaultJSONSerializer, Serializer
 
 # Actor factory Callable type hint.
 ACTOR_FACTORY_CALLBACK = Callable[[ActorInterface, str, str], 'ActorProxy']
@@ -35,8 +35,7 @@ def create(
         actor_type: str,
         actor_id: ActorId,
         actor_interface: Optional[Type[ActorInterface]] = None,
-    ) -> 'ActorProxy':
-        ...
+    ) -> 'ActorProxy': ...
 
 
 class ActorProxyFactory(ActorFactoryBase):

dapr/actor/runtime/_reminder_data.py

@@ -14,7 +14,6 @@
 """
 
 import base64
-
 from datetime import timedelta
 from typing import Any, Dict, Optional
 

dapr/actor/runtime/_state_provider.py

@@ -14,12 +14,11 @@
 """
 
 import io
+from typing import Any, List, Tuple, Type
 
-from typing import Any, List, Type, Tuple
-from dapr.actor.runtime.state_change import StateChangeKind, ActorStateChange
+from dapr.actor.runtime.state_change import ActorStateChange, StateChangeKind
 from dapr.clients.base import DaprActorClientBase
-from dapr.serializers import Serializer, DefaultJSONSerializer
-
+from dapr.serializers import DefaultJSONSerializer, Serializer
 
 # Mapping StateChangeKind to Dapr State Operation
 _MAP_CHANGE_KIND_TO_OPERATION = {

dapr/actor/runtime/_type_information.py

@@ -13,10 +13,10 @@
 limitations under the License.
 """
 
-from dapr.actor.runtime.remindable import Remindable
-from dapr.actor.runtime._type_utils import is_dapr_actor, get_actor_interfaces
+from typing import TYPE_CHECKING, List, Type
 
-from typing import List, Type, TYPE_CHECKING
+from dapr.actor.runtime._type_utils import get_actor_interfaces, is_dapr_actor
+from dapr.actor.runtime.remindable import Remindable
 
 if TYPE_CHECKING:
     from dapr.actor.actor_interface import ActorInterface  # noqa: F401

dapr/actor/runtime/actor.py

@@ -14,16 +14,15 @@
 """
 
 import uuid
-
 from datetime import timedelta
 from typing import Any, Optional
 
 from dapr.actor.id import ActorId
 from dapr.actor.runtime._method_context import ActorMethodContext
-from dapr.actor.runtime.context import ActorRuntimeContext
-from dapr.actor.runtime.state_manager import ActorStateManager
 from dapr.actor.runtime._reminder_data import ActorReminderData
 from dapr.actor.runtime._timer_data import TIMER_CALLBACK, ActorTimerData
+from dapr.actor.runtime.context import ActorRuntimeContext
+from dapr.actor.runtime.state_manager import ActorStateManager
 
 
 class Actor:

dapr/actor/runtime/context.py

@@ -13,16 +13,16 @@
 limitations under the License.
 """
 
+from typing import TYPE_CHECKING, Callable, Optional
+
 from dapr.actor.id import ActorId
 from dapr.actor.runtime._state_provider import StateProvider
 from dapr.clients.base import DaprActorClientBase
 from dapr.serializers import Serializer
 
-from typing import Callable, Optional, TYPE_CHECKING
-
 if TYPE_CHECKING:
-    from dapr.actor.runtime.actor import Actor
     from dapr.actor.runtime._type_information import ActorTypeInformation
+    from dapr.actor.runtime.actor import Actor
 
 
 class ActorRuntimeContext:

dapr/actor/runtime/manager.py

@@ -15,17 +15,16 @@
 
 import asyncio
 import uuid
-
 from typing import Any, Callable, Coroutine, Dict, Optional
 
 from dapr.actor.id import ActorId
-from dapr.clients.exceptions import DaprInternalError
+from dapr.actor.runtime._method_context import ActorMethodContext
+from dapr.actor.runtime._reminder_data import ActorReminderData
 from dapr.actor.runtime.actor import Actor
 from dapr.actor.runtime.context import ActorRuntimeContext
-from dapr.actor.runtime._method_context import ActorMethodContext
 from dapr.actor.runtime.method_dispatcher import ActorMethodDispatcher
-from dapr.actor.runtime._reminder_data import ActorReminderData
 from dapr.actor.runtime.reentrancy_context import reentrancy_ctx
+from dapr.clients.exceptions import DaprInternalError
 
 TIMER_METHOD_NAME = 'fire_timer'
 REMINDER_METHOD_NAME = 'receive_reminder'

dapr/actor/runtime/method_dispatcher.py

@@ -14,9 +14,10 @@
 """
 
 from typing import Any, Dict, List
-from dapr.actor.runtime.actor import Actor
+
 from dapr.actor.runtime._type_information import ActorTypeInformation
 from dapr.actor.runtime._type_utils import get_dispatchable_attrs
+from dapr.actor.runtime.actor import Actor
 
 
 class ActorMethodDispatcher:

dapr/actor/runtime/reentrancy_context.py

@@ -13,7 +13,7 @@
 limitations under the License.
 """
 
-from typing import Optional
 from contextvars import ContextVar
+from typing import Optional
 
 reentrancy_ctx: ContextVar[Optional[str]] = ContextVar('reentrancy_ctx', default=None)