Function validate_source_scan 

pub(crate) fn validate_source_scan(
    plan: &LogicalPlan,
    source_table_id: TableId,
    source_schema: &SchemaRef,
) -> Result<(), Error>

Ensures the retained scan was planned against the source metadata captured for this flow.