Dispatch a physical plan and await the response.
(
state: &AppState,
tenant_id: TenantId,
collection: &str,
plan: PhysicalPlan,
)
| 28 | |
| 29 | /// Dispatch a physical plan and await the response. |
| 30 | pub(super) async fn dispatch_plan( |
| 31 | state: &AppState, |
| 32 | tenant_id: TenantId, |
| 33 | collection: &str, |
| 34 | plan: PhysicalPlan, |
| 35 | ) -> Result<Vec<u8>, ApiError> { |
| 36 | dispatch_plan_with_trace(state, tenant_id, collection, plan, TraceId::ZERO).await |
| 37 | } |
| 38 | |
| 39 | /// Dispatch a physical plan with trace ID and await the response. |
| 40 | pub(super) async fn dispatch_plan_with_trace( |
no test coverage detected