Rename DispatchActor to DispatchingActor

This is to follow the current actors naming convention.

Signed-off-by: Leandro Lucarella <[email protected]>

Author: llucax

src/frequenz/dispatch/_dispatcher.py

@@ -11,7 +11,7 @@
 from frequenz.client.dispatch.types import Dispatch
 
 from frequenz.dispatch._event import DispatchEvent
-from frequenz.dispatch.actor import DispatchActor
+from frequenz.dispatch.actor import DispatchingActor
 
 ReceivedT = TypeVar("ReceivedT")
 """The type being received."""
@@ -77,7 +77,7 @@ def __init__(
         """
         self._ready_channel = Broadcast[Dispatch]("ready_dispatches")
         self._updated_channel = Broadcast[DispatchEvent]("new_dispatches")
-        self._actor = DispatchActor(
+        self._actor = DispatchingActor(
             microgrid_id,
             grpc_channel,
             svc_addr,

src/frequenz/dispatch/actor.py

@@ -56,7 +56,7 @@
 """To map from our Weekday enum to the dateutil library enum."""
 
 
-class DispatchActor(Actor):
+class DispatchingActor(Actor):
     """Dispatch actor.
 
     This actor is responsible for handling dispatches for a microgrid.

tests/test_frequenz_dispatch.py

@@ -20,7 +20,7 @@
 from pytest import fixture
 
 from frequenz.dispatch import Created, Deleted, DispatchEvent, Updated
-from frequenz.dispatch.actor import DispatchActor
+from frequenz.dispatch.actor import DispatchingActor
 
 
 # This method replaces the event loop for all tests in the file.
@@ -50,7 +50,7 @@ def _now() -> datetime:
 class ActorTestEnv:
     """Test environment for the actor."""
 
-    actor: DispatchActor
+    actor: DispatchingActor
     """The actor under test."""
     updated_dispatches: Receiver[DispatchEvent]
     """The receiver for updated dispatches."""
@@ -85,7 +85,7 @@ async def send(self, msg: T) -> None:
     ready_dispatches = Broadcast[Dispatch]("ready_dispatches")
     microgrid_id = randint(1, 100)
 
-    actor = DispatchActor(
+    actor = DispatchingActor(
         microgrid_id=microgrid_id,
         grpc_channel=MagicMock(),
         svc_addr="localhost",
@@ -223,7 +223,7 @@ async def test_dispatch_schedule(
     await actor_env.client.create(**to_create_params(sample))
     dispatch = actor_env.client.dispatches[0]
 
-    next_run = DispatchActor.calculate_next_run(dispatch, _now())
+    next_run = DispatchingActor.calculate_next_run(dispatch, _now())
     assert next_run is not None
 
     fake_time.shift(next_run - _now() - timedelta(seconds=1))