diff --git a/RELEASE_NOTES.md b/RELEASE_NOTES.md index 4bd60ba..10245f1 100644 --- a/RELEASE_NOTES.md +++ b/RELEASE_NOTES.md @@ -2,16 +2,9 @@ ## Summary - +This release updates the minimum required `frequenz-channels` version is updated +to v1.0.0-rc1. This is a breaking change, because the channels API has changed. ## Upgrading - - -## New Features - - - -## Bug Fixes - - +Follow the upgrading instructions from the new channel release: [v1.0.0-rc1](https://github.com/frequenz-floss/frequenz-channels-python/releases/tag/v1.0.0-rc.1). diff --git a/pyproject.toml b/pyproject.toml index 831c9f2..24c448d 100644 --- a/pyproject.toml +++ b/pyproject.toml @@ -28,7 +28,7 @@ classifiers = [ requires-python = ">= 3.11, < 4" # TODO(cookiecutter): Remove and add more dependencies if appropriate dependencies = [ - "frequenz-channels >= v1.0.0-beta.2, < 2", + "frequenz-channels >= v1.0.0-rc1, < 2", "grpcio >= 1.54.2, < 2", "protobuf >= 4.21.6, < 5", "typing-extensions >= 4.5.0, < 5", diff --git a/src/frequenz/client/base/streaming.py b/src/frequenz/client/base/streaming.py index ea6e1f1..ba0451a 100644 --- a/src/frequenz/client/base/streaming.py +++ b/src/frequenz/client/base/streaming.py @@ -51,7 +51,7 @@ def __init__( ) self._channel: channels.Broadcast[OutputT] = channels.Broadcast( - f"GrpcStreamBroadcaster-{stream_name}" + name=f"GrpcStreamBroadcaster-{stream_name}" ) self._task = asyncio.create_task(self._run()) @@ -64,7 +64,7 @@ def new_receiver(self, maxsize: int = 50) -> channels.Receiver[OutputT]: Returns: A new receiver. """ - return self._channel.new_receiver(maxsize=maxsize) + return self._channel.new_receiver(limit=maxsize) async def stop(self) -> None: """Stop the streaming helper."""