Fix tests

Signed-off-by: Mathias L. Baumann <[email protected]>

Author: Marenz

tests/test_frequenz_dispatch.py

@@ -473,12 +473,13 @@ async def test_dispatch_new_but_finished(
         new_dispatch,
         active=True,
         duration=timedelta(seconds=10),
-        start_time=_now() + timedelta(seconds=5),
+        start_time=_now() + timedelta(seconds=500),
         recurrence=RecurrenceRule(),
         type="TEST_TYPE",
     )
 
     new_dispatch = await _test_new_dispatch_created(test_env, new_dispatch)
+    assert new_dispatch.started is False
 
     # Advance time to when the new dispatch should still not start
     fake_time.shift(timedelta(seconds=100))

tests/test_mananging_actor.py

@@ -344,10 +344,15 @@ def __init__(self, *, server_url: str, key: str):
         sender = channel.new_sender()
 
         async def new_mock_receiver(
-            _: Dispatcher, dispatch_type: str, *, merge_strategy: MergeStrategy | None
+            _: Dispatcher,
+            dispatch_type: str,
+            *,
+            merge_strategy: MergeStrategy | None,
+            initial_fetch_timeout: timedelta = timedelta(seconds=10),
         ) -> Receiver[Dispatch]:
             assert dispatch_type == "MANAGE_TEST"
             assert merge_strategy is strategy
+            assert initial_fetch_timeout == timedelta(seconds=10)
             return channel.new_receiver()
 
         with patch(
@@ -363,6 +368,7 @@ async def new_mock_receiver(
         # pylint: disable=protected-access
         assert "MANAGE_TEST" in dispatcher._actor_dispatchers
         actor_manager = dispatcher._actor_dispatchers["MANAGE_TEST"]
+        # pylint: disable=comparison-with-callable
         assert actor_manager._actor_factory == MockActor.create
 
         dispatch = Dispatch(