diff --git a/tests/test_capture_v2_collector_cli_transport.py b/tests/test_capture_v2_collector_cli_transport.py index 071a55b..3060c7c 100644 --- a/tests/test_capture_v2_collector_cli_transport.py +++ b/tests/test_capture_v2_collector_cli_transport.py @@ -258,11 +258,14 @@ def test_full_eight_stream_bounded_probe_archives_and_normalizes(tmp_path: Path) http=FakeHttp(), websockets=connector, clock=clock, + monotonic=lambda: 0.0, jitter=lambda: 0.5, policy=POLICY, ) report = asyncio.run(coordinator.run(maximum_websocket_messages=3)) - assert report.status == "BOUNDED_PROBE_COMPLETE" + assert report.status == "BOUNDED_PROBE_COMPLETE", [ + (item.stream_id, item.errors) for item in report.streams if item.errors + ] assert report.providers == ("binance", "okx") assert report.capabilities == ( "btc-spot-l2", diff --git a/tests/test_capture_v2_remediation.py b/tests/test_capture_v2_remediation.py index 3841354..148aff5 100644 --- a/tests/test_capture_v2_remediation.py +++ b/tests/test_capture_v2_remediation.py @@ -1301,11 +1301,14 @@ def test_coordinator_reports_reconciled_epoch_before_network( http=collector_fixtures.FakeHttp(), websockets=collector_fixtures.FakeConnector(streams), clock=collector_fixtures.FakeClock(), + monotonic=lambda: 0.0, alert_sink=alerts.append, policy=collector_fixtures.POLICY, ) report = asyncio.run(coordinator.run(maximum_websocket_messages=3)) - assert report.status == "BOUNDED_PROBE_COMPLETE" + assert report.status == "BOUNDED_PROBE_COMPLETE", [ + (item.stream_id, item.errors) for item in report.streams if item.errors + ] assert "CAPTURE_EPOCH_RECOVERY_COMMITTED:1" in alerts