pub(crate) fn render_tx<G, FromTime: Timestamp>(
    envelope: &DebeziumEnvelope,
    input: &Collection<G, DecodeResult<FromTime>, Diff>,
    tx_ok: Collection<G, Row, Diff>
) -> (Collection<G, Row, Diff>, Collection<G, DataflowError, Diff>)where
    G: ScopeParent<Timestamp = Timestamp> + Scope,