Skip to content

Commit df88828

Browse files
committed
Limit status update receiver queue to 1 and disable warning
Signed-off-by: Mathias L. Baumann <[email protected]>
1 parent e4fea21 commit df88828

File tree

2 files changed

+3
-2
lines changed

2 files changed

+3
-2
lines changed

pyproject.toml

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -39,7 +39,7 @@ dependencies = [
3939
# mkdocs.yml file when changing the version here (look for the config key
4040
# plugins.mkdocstrings.handlers.python.import)
4141
"frequenz-sdk >= 1.0.0-rc1302, < 1.0.0-rc1600",
42-
"frequenz-channels >= 1.3.0, < 2.0.0",
42+
"frequenz-channels >= 1.6.1, < 2.0.0",
4343
"frequenz-client-dispatch >= 0.8.4, < 0.9.0",
4444
]
4545
dynamic = ["version"]

src/frequenz/dispatch/_actor_dispatcher.py

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -186,7 +186,8 @@ async def _start_actor(self, dispatch: Dispatch) -> None:
186186
else:
187187
_logger.info("Starting actor for dispatch type %r", dispatch.type)
188188
actor = self._actor_factory(
189-
dispatch_update, self._updates_channel.new_receiver()
189+
dispatch_update,
190+
self._updates_channel.new_receiver(limit=1, warn_on_overflow=False),
190191
)
191192
self._actors[self._map_dispatch(dispatch)] = actor
192193

0 commit comments

Comments
 (0)