Method dispatch_task

nodedb/src/control/server/pgwire/handler/dispatch.rs:23–41

Dispatch a single physical task and wait for the response. In cluster mode, write operations are proposed to Raft first and only executed on the Data Plane after quorum commit. Reads bypass Raft. `user_id` is forwarded to the `Request` for DML audit attribution. Pass `None` for system-generated tasks (triggers, maintenance, etc.).

(
        &self,
        task: PhysicalTask,
        user_id: Option<Arc<str>>,
    )

    /// `user_id` is forwarded to the `Request` for DML audit attribution.
    /// Pass `None` for system-generated tasks (triggers, maintenance, etc.).
    pub(super) async fn dispatch_task(
        &self,
        task: PhysicalTask,
        user_id: Option<Arc<str>>,
    ) -> crate::Result<Response> {
        let tenant_id = task.tenant_id;
        let result = self.dispatch_task_inner(task, user_id).await;
        // Advance per-tenant observed write-HLC high-water on any
        // successful dispatch (local, raft-replicated, or broadcast).
        // Used by RESTORE's staleness gate. Backup captures envelope
        // watermark AFTER its own fan-out, so envelope.wm dominates
        // tenant_wm on a fresh backup.
        if let Ok(ref resp) = result
            && resp.status == crate::bridge::envelope::Status::Ok
        {
            self.state.advance_tenant_write_hlc(tenant_id.as_u64());
        }
        result
    }

    async fn dispatch_task_inner(
        &self,