Skip to content

Commit

Permalink
Update minimum frequenz-channels version to v1.0.0-rc1
Browse files Browse the repository at this point in the history
Signed-off-by: Sahas Subramanian <sahas.subramanian@proton.me>
  • Loading branch information
shsms committed Mar 11, 2024
1 parent 97196bd commit 31de004
Show file tree
Hide file tree
Showing 2 changed files with 3 additions and 3 deletions.
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 31de004

Please sign in to comment.