Bypass loop time in *Pool tests with async_solipsism

This eliminates flakiness coming from running tests in slow or
software-emulated VMs.

Signed-off-by: Sahas Subramanian <[email protected]>

Author: shsms

tests/timeseries/_battery_pool/test_battery_pool_control_methods.py

@@ -9,6 +9,7 @@
 from datetime import datetime, timedelta, timezone
 from unittest.mock import AsyncMock, MagicMock
 
+import async_solipsism
 import pytest
 from frequenz.channels import LatestValueCache, Sender
 from pytest_mock import MockerFixture
@@ -27,6 +28,12 @@
 from ..mock_microgrid import MockMicrogrid
 
 
+@pytest.fixture
+def event_loop_policy() -> async_solipsism.EventLoopPolicy:
+    """Event loop policy."""
+    return async_solipsism.EventLoopPolicy()
+
+
 @dataclasses.dataclass(frozen=True)
 class Mocks:
     """Mocks for the tests."""
@@ -89,11 +96,6 @@ async def _patch_battery_pool_status(
         If `battery_ids` is not None, the mock will always return `battery_ids`.
         Otherwise, it will return the requested batteries.
         """
-        mocker.patch.object(
-            timeseries.battery_pool._methods,  # pylint: disable=protected-access
-            "WAIT_FOR_COMPONENT_DATA_SEC",
-            0.1,
-        )
         if battery_ids:
             mock = MagicMock(spec=ComponentPoolStatusTracker)
             mock.get_working_components.return_value = battery_ids

tests/timeseries/_ev_charger_pool/test_ev_charger_pool_control_methods.py

@@ -8,6 +8,7 @@
 from datetime import datetime, timedelta, timezone
 from unittest.mock import AsyncMock, MagicMock
 
+import async_solipsism
 import pytest
 from frequenz.channels import Receiver
 from frequenz.client.microgrid import EVChargerCableState, EVChargerComponentState
@@ -38,6 +39,12 @@
 # pylint: disable=protected-access
 
 
+@pytest.fixture
+def event_loop_policy() -> async_solipsism.EventLoopPolicy:
+    """Event loop policy."""
+    return async_solipsism.EventLoopPolicy()
+
+
 @pytest.fixture
 async def mocks(mocker: MockerFixture) -> typing.AsyncIterator[_Mocks]:
     """Create the mocks."""

tests/timeseries/_pv_pool/test_pv_pool_control_methods.py

@@ -8,6 +8,7 @@
 from datetime import datetime, timedelta, timezone
 from unittest.mock import AsyncMock
 
+import async_solipsism
 import pytest
 from frequenz.channels import Receiver
 from frequenz.client.microgrid import InverterComponentState
@@ -25,6 +26,12 @@
 from ..mock_microgrid import MockMicrogrid
 
 
+@pytest.fixture
+def event_loop_policy() -> async_solipsism.EventLoopPolicy:
+    """Event loop policy."""
+    return async_solipsism.EventLoopPolicy()
+
+
 @pytest.fixture
 async def mocks(mocker: MockerFixture) -> typing.AsyncIterator[_Mocks]:
     """Create the mocks."""