Apply ruff autoformatter

Signed-off-by: Bernd Verst <[email protected]>

dapr/actor/client/proxy.py

@@ -34,8 +34,7 @@ def create(
         actor_type: str,
         actor_id: ActorId,
         actor_interface: Optional[Type[ActorInterface]] = None,
-    ) -> 'ActorProxy':
-        ...
+    ) -> 'ActorProxy': ...
 
 
 class ActorProxyFactory(ActorFactoryBase):

dapr/actor/runtime/_state_provider.py

@@ -97,7 +97,7 @@ async def save_state(
                 serialized = self._state_serializer.serialize(state.value)
                 json_output.write(b',"value":')
                 json_output.write(serialized)
-            if  state.ttl_in_seconds is not None and state.ttl_in_seconds >= 0:
+            if state.ttl_in_seconds is not None and state.ttl_in_seconds >= 0:
                 serialized = self._state_serializer.serialize(state.ttl_in_seconds)
                 json_output.write(b',"metadata":{"ttlInSeconds":"')
                 json_output.write(serialized)

dapr/actor/runtime/state_change.py

@@ -35,7 +35,13 @@ class StateChangeKind(Enum):
 
 
 class ActorStateChange(Generic[T]):
-    def __init__(self, state_name: str, value: T, change_kind: StateChangeKind, ttl_in_seconds: Optional[int] = None):
+    def __init__(
+        self,
+        state_name: str,
+        value: T,
+        change_kind: StateChangeKind,
+        ttl_in_seconds: Optional[int] = None,
+    ):
         self._state_name = state_name
         self._value = value
         self._change_kind = change_kind

dapr/actor/runtime/state_manager.py

@@ -29,7 +29,9 @@
 
 
 class StateMetadata(Generic[T]):
-    def __init__(self, value: T, change_kind: StateChangeKind, ttl_in_seconds: Optional[int] = None):
+    def __init__(
+        self, value: T, change_kind: StateChangeKind, ttl_in_seconds: Optional[int] = None
+    ):
         self._value = value
         self._change_kind = change_kind
         self._ttl_in_seconds = ttl_in_seconds
@@ -136,9 +138,13 @@ async def set_state_ttl(self, state_name: str, value: T, ttl_in_seconds: Optiona
             self._type_name, self._actor.id.id, state_name
         )
         if existed:
-            state_change_tracker[state_name] = StateMetadata(value, StateChangeKind.update, ttl_in_seconds)
+            state_change_tracker[state_name] = StateMetadata(
+                value, StateChangeKind.update, ttl_in_seconds
+            )
         else:
-            state_change_tracker[state_name] = StateMetadata(value, StateChangeKind.add, ttl_in_seconds)
+            state_change_tracker[state_name] = StateMetadata(
+                value, StateChangeKind.add, ttl_in_seconds
+            )
 
     async def remove_state(self, state_name: str) -> None:
         if not await self.try_remove_state(state_name):
@@ -247,7 +253,12 @@ async def save_state(self) -> None:
             if state_metadata.change_kind == StateChangeKind.none:
                 continue
             state_changes.append(
-                ActorStateChange(state_name, state_metadata.value, state_metadata.change_kind, state_metadata.ttl_in_seconds)
+                ActorStateChange(
+                    state_name,
+                    state_metadata.value,
+                    state_metadata.change_kind,
+                    state_metadata.ttl_in_seconds,
+                )
             )
             if state_metadata.change_kind == StateChangeKind.remove:
                 states_to_remove.append(state_name)

dapr/clients/base.py

@@ -27,31 +27,28 @@ class DaprActorClientBase(ABC):
     @abstractmethod
     async def invoke_method(
         self, actor_type: str, actor_id: str, method: str, data: Optional[bytes] = None
-    ) -> bytes:
-        ...
+    ) -> bytes: ...
 
     @abstractmethod
-    async def save_state_transactionally(self, actor_type: str, actor_id: str, data: bytes) -> None:
-        ...
+    async def save_state_transactionally(
+        self, actor_type: str, actor_id: str, data: bytes
+    ) -> None: ...
 
     @abstractmethod
-    async def get_state(self, actor_type: str, actor_id: str, name: str) -> bytes:
-        ...
+    async def get_state(self, actor_type: str, actor_id: str, name: str) -> bytes: ...
 
     @abstractmethod
     async def register_reminder(
         self, actor_type: str, actor_id: str, name: str, data: bytes
-    ) -> None:
-        ...
+    ) -> None: ...
 
     @abstractmethod
-    async def unregister_reminder(self, actor_type: str, actor_id: str, name: str) -> None:
-        ...
+    async def unregister_reminder(self, actor_type: str, actor_id: str, name: str) -> None: ...
 
     @abstractmethod
-    async def register_timer(self, actor_type: str, actor_id: str, name: str, data: bytes) -> None:
-        ...
+    async def register_timer(
+        self, actor_type: str, actor_id: str, name: str, data: bytes
+    ) -> None: ...
 
     @abstractmethod
-    async def unregister_timer(self, actor_type: str, actor_id: str, name: str) -> None:
-        ...
+    async def unregister_timer(self, actor_type: str, actor_id: str, name: str) -> None: ...

dapr/clients/exceptions.py

@@ -12,6 +12,7 @@
 See the License for the specific language governing permissions and
 limitations under the License.
 """
+
 import json
 from typing import Optional
 

dapr/clients/grpc/_helpers.py

@@ -12,6 +12,7 @@
 See the License for the specific language governing permissions and
 limitations under the License.
 """
+
 from collections import namedtuple
 from typing import Dict, List, Union, Tuple, Optional
 from enum import Enum

dapr/clients/health.py

@@ -12,6 +12,7 @@
 See the License for the specific language governing permissions and
 limitations under the License.
 """
+
 import urllib.request
 import urllib.error
 import time

dapr/serializers/base.py

@@ -23,14 +23,12 @@ class Serializer(ABC):
     @abstractmethod
     def serialize(
         self, obj: object, custom_hook: Optional[Callable[[object], bytes]] = None
-    ) -> bytes:
-        ...
+    ) -> bytes: ...
 
     @abstractmethod
     def deserialize(
         self,
         data: bytes,
         data_type: Optional[Type] = object,
         custom_hook: Optional[Callable[[bytes], object]] = None,
-    ) -> Any:
-        ...
+    ) -> Any: ...

examples/demo_actor/demo_actor/demo_actor_interface.py

@@ -18,30 +18,24 @@
 class DemoActorInterface(ActorInterface):
     @abstractmethod
     @actormethod(name='GetMyData')
-    async def get_my_data(self) -> object:
-        ...
+    async def get_my_data(self) -> object: ...
 
     @abstractmethod
     @actormethod(name='SetMyData')
-    async def set_my_data(self, data: object) -> None:
-        ...
+    async def set_my_data(self, data: object) -> None: ...
 
     @abstractmethod
     @actormethod(name='ClearMyData')
-    async def clear_my_data(self) -> None:
-        ...
+    async def clear_my_data(self) -> None: ...
 
     @abstractmethod
     @actormethod(name='SetReminder')
-    async def set_reminder(self, enabled: bool) -> None:
-        ...
+    async def set_reminder(self, enabled: bool) -> None: ...
 
     @abstractmethod
     @actormethod(name='SetTimer')
-    async def set_timer(self, enabled: bool) -> None:
-        ...
+    async def set_timer(self, enabled: bool) -> None: ...
 
     @abstractmethod
     @actormethod(name='GetReentrancyStatus')
-    async def get_reentrancy_status(self) -> bool:
-        ...
+    async def get_reentrancy_status(self) -> bool: ...

examples/grpc_proxying/helloworld_service_pb2_grpc.py

@@ -1,5 +1,6 @@
 # Generated by the gRPC Python protocol compiler plugin. DO NOT EDIT!
 """Client and server classes corresponding to protobuf-defined services."""
+
 import grpc
 
 import helloworld_service_pb2 as helloworld__service__pb2

examples/invoke-custom-data/proto/response_pb2_grpc.py

@@ -1,3 +1,4 @@
 # Generated by the gRPC Python protocol compiler plugin. DO NOT EDIT!
 """Client and server classes corresponding to protobuf-defined services."""
+
 import grpc

ext/dapr-ext-grpc/dapr/ext/grpc/_servicier.py

@@ -12,6 +12,7 @@
 See the License for the specific language governing permissions and
 limitations under the License.
 """
+
 import grpc
 
 from cloudevents.sdk.event import v1  # type: ignore

tests/actor/fake_actor_classes.py

@@ -12,6 +12,7 @@
 See the License for the specific language governing permissions and
 limitations under the License.
 """
+
 from dapr.serializers.json import DefaultJSONSerializer
 import asyncio
 
@@ -28,8 +29,7 @@
 # Fake Simple Actor Class for testing
 class FakeSimpleActorInterface(ActorInterface):
     @actormethod(name='ActorMethod')
-    async def actor_method(self, arg: int) -> dict:
-        ...
+    async def actor_method(self, arg: int) -> dict: ...
 
 
 class FakeSimpleActor(Actor, FakeSimpleActorInterface):
@@ -89,40 +89,32 @@ async def receive_reminder(
 class FakeActorCls1Interface(ActorInterface):
     # Fake Actor Class deriving multiple ActorInterfaces
     @actormethod(name='ActorCls1Method')
-    async def actor_cls1_method(self, arg):
-        ...
+    async def actor_cls1_method(self, arg): ...
 
     @actormethod(name='ActorCls1Method1')
-    async def actor_cls1_method1(self, arg):
-        ...
+    async def actor_cls1_method1(self, arg): ...
 
     @actormethod(name='ActorCls1Method2')
-    async def actor_cls1_method2(self, arg):
-        ...
+    async def actor_cls1_method2(self, arg): ...
 
 
 class FakeActorCls2Interface(ActorInterface):
     @actormethod(name='ActorCls2Method')
-    async def actor_cls2_method(self, arg):
-        ...
+    async def actor_cls2_method(self, arg): ...
 
     @actormethod(name='ActionMethod')
-    async def action(self, data: object) -> str:
-        ...
+    async def action(self, data: object) -> str: ...
 
     @actormethod(name='ActionMethodWithoutArg')
-    async def action_no_arg(self) -> str:
-        ...
+    async def action_no_arg(self) -> str: ...
 
 
 class ReentrantActorInterface(ActorInterface):
     @actormethod(name='ReentrantMethod')
-    async def reentrant_method(self, data: object) -> str:
-        ...
+    async def reentrant_method(self, data: object) -> str: ...
 
     @actormethod(name='ReentrantMethodWithPassthrough')
-    async def reentrant_pass_through_method(self, arg):
-        ...
+    async def reentrant_pass_through_method(self, arg): ...
 
 
 class FakeMultiInterfacesActor(

tests/actor/fake_client.py

@@ -21,28 +21,25 @@
 class FakeDaprActorClientBase(DaprActorClientBase):
     async def invoke_method(
         self, actor_type: str, actor_id: str, method: str, data: Optional[bytes] = None
-    ) -> bytes:
-        ...
+    ) -> bytes: ...
 
-    async def save_state_transactionally(self, actor_type: str, actor_id: str, data: bytes) -> None:
-        ...
+    async def save_state_transactionally(
+        self, actor_type: str, actor_id: str, data: bytes
+    ) -> None: ...
 
-    async def get_state(self, actor_type: str, actor_id: str, name: str) -> bytes:
-        ...
+    async def get_state(self, actor_type: str, actor_id: str, name: str) -> bytes: ...
 
     async def register_reminder(
         self, actor_type: str, actor_id: str, name: str, data: bytes
-    ) -> None:
-        ...
+    ) -> None: ...
 
-    async def unregister_reminder(self, actor_type: str, actor_id: str, name: str) -> None:
-        ...
+    async def unregister_reminder(self, actor_type: str, actor_id: str, name: str) -> None: ...
 
-    async def register_timer(self, actor_type: str, actor_id: str, name: str, data: bytes) -> None:
-        ...
+    async def register_timer(
+        self, actor_type: str, actor_id: str, name: str, data: bytes
+    ) -> None: ...
 
-    async def unregister_timer(self, actor_type: str, actor_id: str, name: str) -> None:
-        ...
+    async def unregister_timer(self, actor_type: str, actor_id: str, name: str) -> None: ...
 
 
 class FakeDaprActorClient(FakeDaprActorClientBase):

tests/actor/test_client_proxy.py

@@ -12,6 +12,7 @@
 See the License for the specific language governing permissions and
 limitations under the License.
 """
+
 import unittest
 
 from unittest import mock

tests/clients/test_dapr_grpc_client_secure.py

@@ -12,6 +12,7 @@
 See the License for the specific language governing permissions and
 limitations under the License.
 """
+
 import unittest
 from unittest.mock import patch
 

tests/clients/test_heatlhcheck.py

@@ -12,6 +12,7 @@
 See the License for the specific language governing permissions and
 limitations under the License.
 """
+
 import time
 import unittest
 from unittest.mock import patch, MagicMock

tests/clients/test_secure_http_service_invocation_client.py

@@ -12,6 +12,7 @@
 See the License for the specific language governing permissions and
 limitations under the License.
 """
+
 import ssl
 import typing
 from asyncio import TimeoutError

tox.ini

@@ -35,7 +35,7 @@ commands =
 [testenv:ruff]
 basepython = python3
 usedevelop = False
-deps = ruff==0.2.2
+deps = ruff==0.4.2
 commands =
     ruff format