# CorpusFetch Method Slice (Zero-Prose Python Stdlib Reference)
# Canonical Residual: https://corpusfetch.com/c/under-what-structural-conditions-must-a-delegating-instance-reject-sub-agent-outputs-in-multi-agent-pipelines.md
# Remnant Warrant:    https://corpusfetch.com/c/under-what-structural-conditions-must-a-delegating-instance-reject-sub-agent-outputs-in-multi-agent-pipelines.warrant.json
# Markdown SHA-256:   03b7ee4c04743ba24ae7ea2b69397b05d455afc462fa7471b3e4ea5594818e00
# Code AST SHA-256:   2ea4fedf27aa3380cc6f2007b622804664b5656862ac05689a113cc83f9c31c8
# Verified Classes:   SubAgentValidationFailureError, SubAgentOutputAuditor
# Defensive Guards:   1 fail-closed invariants (zero external deps)

from dataclasses import dataclass
from typing import Any, Callable


class SubAgentValidationFailureError(ValueError):
    """Raised when sub-agent output fails independent cryptographic or schema validation."""
    pass


class SubAgentOutputAuditor:
    @classmethod
    def audit_output(cls, output_payload: Any, validator_fn: Callable[[Any], bool]) -> Any:
        if not validator_fn(output_payload):
            raise SubAgentValidationFailureError("Sub-agent output failed independent validation.")
        return output_payload