Prevent getting warning loggings when the streaming channels overflow

    * Set warn_on_overflow to False to ignore warnigns
    * Increase the channel size from 50 to 100

Signed-off-by: camille-bouvy-frequenz <[email protected]>

Author: camille-bouvy-frequenz

pyproject.toml

@@ -31,8 +31,8 @@ dependencies = [
   "entsoe-py >= 0.6.16, < 1",
   "frequenz-api-common >= 0.6.3, < 0.7.0",
   "grpcio >= 1.66.2, < 2",
-  "frequenz-channels >= 1.0.0, < 2",
-  "frequenz-client-base >= 0.8.0, < 0.9.0",
+  "frequenz-channels >= 1.6.1, < 2",
+  "frequenz-client-base >= 0.9.0, < 0.10.0",
   "frequenz-client-common >= 0.1.0, < 0.3.0",
   "frequenz-api-electricity-trading >= 0.2.4, < 1",
   "protobuf >= 5.28.0, < 6",

src/frequenz/client/electricity_trading/_client.py

@@ -3,6 +3,8 @@
 
 """Module to define the client class."""
 
+# pylint: disable=too-many-lines
+
 from __future__ import annotations
 
 import asyncio
@@ -273,7 +275,9 @@ async def stream_gridpool_orders(
                     "Error occurred while streaming gridpool orders: %s", e
                 )
                 raise
-        return self._gridpool_orders_streams[stream_key].new_receiver()
+        return self._gridpool_orders_streams[stream_key].new_receiver(
+            warn_on_overflow=False, maxsize=100
+        )
 
     async def stream_gridpool_trades(
         # pylint: disable=too-many-arguments, too-many-positional-arguments
@@ -332,7 +336,9 @@ async def stream_gridpool_trades(
                     "Error occurred while streaming gridpool trades: %s", e
                 )
                 raise
-        return self._gridpool_trades_streams[stream_key].new_receiver()
+        return self._gridpool_trades_streams[stream_key].new_receiver(
+            warn_on_overflow=False, maxsize=100
+        )
 
     async def stream_public_trades(
         self,
@@ -382,7 +388,9 @@ async def stream_public_trades(
             except grpc.RpcError as e:
                 _logger.exception("Error occurred while streaming public trades: %s", e)
                 raise
-        return self._public_trades_streams[public_trade_filter].new_receiver()
+        return self._public_trades_streams[public_trade_filter].new_receiver(
+            warn_on_overflow=False, maxsize=100
+        )
 
     def validate_params(
         # pylint: disable=too-many-arguments, too-many-positional-arguments, too-many-branches