(
state: &Arc<SharedState>,
tenant_id: u64,
plan: &PhysicalPlan,
)
| 184 | } |
| 185 | |
| 186 | async fn snapshot_self( |
| 187 | state: &Arc<SharedState>, |
| 188 | tenant_id: u64, |
| 189 | plan: &PhysicalPlan, |
| 190 | ) -> Result<Vec<u8>, Error> { |
| 191 | sync_dispatch::dispatch_async( |
| 192 | state, |
| 193 | TenantId::new(tenant_id), |
| 194 | "__system", |
| 195 | plan.clone(), |
| 196 | NODE_SNAPSHOT_TIMEOUT, |
| 197 | ) |
| 198 | .await |
| 199 | } |
| 200 | |
| 201 | async fn snapshot_remote( |
| 202 | state: &Arc<SharedState>, |
no test coverage detected