Test server

ValidationServerRig dataclass

ValidationServerRig(session: ValidationSession, registry: FakeBucketRegistry, index: DataFrame, label: Label, reader: MockS3TSVReader, logger: MockS3TSVWriter, manager: ValidationManager)

run_to_completion

run_to_completion() -> None

Run the validator loop synchronously.

Tests using this must push a terminal client row, or this can spin forever. That is deliberate.

bucket_factory_for

bucket_factory_for(registry: FakeBucketRegistry) -> Callable[[str, ...], FakeMutableBucket]

Return the Bucket replacement used by validation-core construction.

install_validation_server_fakes

install_validation_server_fakes(monkeypatch: MonkeyPatch, registry: FakeBucketRegistry) -> None

Patch validation-core external collaborators to deterministic fakes.