Method commit_tx

crates/engine/src/relational_db.rs:817–835

(
        &self,
        tx: MutTx,
    )

    #[tracing::instrument(level = "trace", skip_all)]
    #[allow(clippy::type_complexity)]
    pub fn commit_tx(
        &self,
        tx: MutTx,
    ) -> Result<Option<(TxOffset, Arc<TxData>, TxMetrics, Option<ReducerName>)>, DBError> {
        log::trace!("COMMIT MUT TX");

        let reducer_context = tx.ctx.reducer_context().cloned();
        // TODO: Never returns `None` -- should it?
        let Some((tx_offset, tx_data, tx_metrics, reducer)) = self.inner.commit_mut_tx_and_then(tx, |tx_data| {
            self.request_durability(reducer_context, tx_data);
        })?
        else {
            return Ok(None);
        };

        self.maybe_do_snapshot(&tx_data);

        Ok(Some((tx_offset, tx_data, tx_metrics, reducer)))
    }

    #[tracing::instrument(level = "trace", skip_all)]
    pub fn commit_tx_downgrade(&self, tx: MutTx, workload: Workload) -> (Arc<TxData>, TxMetrics, Tx) {