Function snapshot_output 

async fn snapshot_output(
    config: &RawSourceCreationConfig,
    client: &Client,
    raw_handles: &mut SharedFuel<MzOffset, CapacityContainerBuilder<Vec<(Result<Bytes, DataflowError>, MzOffset, Diff)>>>,
    cap: &Capability<MzOffset>,
    output_index: usize,
    info: &SourceOutputInfo,
    snapshot_info: &SnapshotInfo,
) -> Result<(), TransientError>

Copies this worker’s share of the table of info to the data output output_index at cap. A schema mismatch is emitted as a definite error in place of the table’s rows.