Function mz_storage::render::upsert::process_upsert_state_error

source ·

async fn process_upsert_state_error<G: Scope>(
    context: String,
    e: Error,
    health_output: &mut AsyncOutputHandle<<G as ScopeParent>::Timestamp, Vec<(usize, HealthStatusUpdate)>, TeeCore<<G as ScopeParent>::Timestamp, Vec<(usize, HealthStatusUpdate)>>>,
    health_cap: &Capability<<G as ScopeParent>::Timestamp>
)

Expand description

Emit the given error, and stall till the dataflow is restarted.