Skip to content

Commit

Permalink
Update minimum frequenz-channels version to v1.0.0-rc1 (#35)
Browse files Browse the repository at this point in the history
  • Loading branch information
shsms committed Mar 11, 2024
2 parents 97196bd + e21cc53 commit 6230161
Show file tree
Hide file tree
Showing 3 changed files with 6 additions and 13 deletions.
13 changes: 3 additions & 10 deletions RELEASE_NOTES.md
Original file line number Diff line number Diff line change
Expand Up @@ -2,16 +2,9 @@

## Summary

<!-- Here goes a general summary of what this release is about -->
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

<!-- Here goes notes on how to upgrade from previous versions, including deprecations and what they should be replaced with -->

## New Features

<!-- Here goes the main new features and examples or instructions on how to use them -->

## Bug Fixes

<!-- Here goes notable bug fixes that are worth a special mention or explanation -->
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).
2 changes: 1 addition & 1 deletion pyproject.toml
Original file line number Diff line number Diff line change
Expand Up @@ -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",
Expand Down
4 changes: 2 additions & 2 deletions src/frequenz/client/base/streaming.py
Original file line number Diff line number Diff line change
Expand Up @@ -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())

Expand All @@ -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."""
Expand Down

0 comments on commit 6230161

Please sign in to comment.