Function mz_storage::upsert::process_upsert_state_error

source ยท 
async fn process_upsert_state_error<G: Scope>(
    context: String,
    e: Error,
    health_output: &AsyncOutputHandle<<G as ScopeParent>::Timestamp, CapacityContainerBuilder<Vec<(usize, HealthStatusUpdate)>>, Tee<<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.