Function execute_with_in_tx_substitute 

pub fn execute_with_in_tx_substitute(
    plan: &LogicalPlan,
    in_tx_rows: Vec<Row>,
    reader: &dyn GraphReader,
    writer: &dyn GraphWriter,
    params: &ParamMap,
    procedures: &ProcedureRegistry,
) -> Result<Vec<Row>>

Run plan with a pre-materialised set of rows substituted for the (single) LogicalPlan::CallSubqueryInTransactions node in the tree. Used by MeshService::execute_call_in_transactions to fold its already-batched-and-committed body output back into the regular pipeline so wrapping clauses (Project / OrderBy / Limit / Aggregate / Filter) can run untouched.

Panics at build time if the plan doesn’t contain exactly one IN TRANSACTIONS node. The dispatcher detects the wrapping shape before calling this, so reaching that panic indicates a wiring bug.