mz_storage::upsert

Function 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<(Option<GlobalId>, HealthStatusUpdate)>>, Tee<<G as ScopeParent>::Timestamp, Vec<(Option<GlobalId>, HealthStatusUpdate)>>>,
    health_cap: &Capability<<G as ScopeParent>::Timestamp>,
)
Expand description

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