Skip to main content

validate_source_schema_version

Function validate_source_schema_version 

Source
fn validate_source_schema_version(
    retained_version: u32,
    current_version: u32,
) -> Result<(), Error>
Expand description

Rejects execution when the source metadata changed after the flow plan was retained. The outer adapter replans a flow when it observes a new source schema version; this guard rejects a request if the version changes again before execution.