Skip to content

Commit 85a7ff3

Browse files
committed
Rename updated_dispatches and ready_dispatches
We use `lifecycle_events` and `ready_to_execute` respectively to make it more clear that the former provides events for any kind of dispatch changes, including creates and deletes, and that the later provides dispatches that are ready to be executed. Signed-off-by: Leandro Lucarella <[email protected]>
1 parent dfb8829 commit 85a7ff3

File tree

1 file changed

+4
-4
lines changed

1 file changed

+4
-4
lines changed

src/frequenz/dispatch/_dispatcher.py

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -60,8 +60,8 @@ async def run():
6060
service_address = "localhost:50051"
6161
dispatcher = Dispatcher(microgrid_id, grpc_channel, service_address)
6262
dispatcher.start() # this will start the actor
63-
dispatch_arrived = dispatcher.updated_dispatches.new_receiver()
64-
dispatch_ready = dispatcher.ready_dispatches.new_receiver()
63+
events = dispatcher.lifecycle_events.new_receiver()
64+
ready = dispatcher.ready_to_execute.new_receiver()
6565
```
6666
"""
6767

@@ -90,7 +90,7 @@ async def start(self) -> None:
9090
self._actor.start()
9191

9292
@property
93-
def updated_dispatches(self) -> ReceiverFetcher[DispatchEvent]:
93+
def lifecycle_events(self) -> ReceiverFetcher[DispatchEvent]:
9494
"""Return new, updated or deleted dispatches receiver.
9595
9696
Returns:
@@ -99,7 +99,7 @@ def updated_dispatches(self) -> ReceiverFetcher[DispatchEvent]:
9999
return self._updated_channel
100100

101101
@property
102-
def ready_dispatches(self) -> ReceiverFetcher[Dispatch]:
102+
def ready_to_execute(self) -> ReceiverFetcher[Dispatch]:
103103
"""Return ready dispatches receiver.
104104
105105
Returns:

0 commit comments

Comments
 (0)