Convert a list of SqlPlans to PhysicalTasks.
(
plans: &[SqlPlan],
tenant_id: TenantId,
ctx: &ConvertContext,
)
| 88 | |
| 89 | /// Convert a list of SqlPlans to PhysicalTasks. |
| 90 | pub fn convert( |
| 91 | plans: &[SqlPlan], |
| 92 | tenant_id: TenantId, |
| 93 | ctx: &ConvertContext, |
| 94 | ) -> crate::Result<Vec<PhysicalTask>> { |
| 95 | let mut tasks = Vec::new(); |
| 96 | for plan in plans { |
| 97 | tasks.extend(convert_one(plan, tenant_id, ctx)?); |
| 98 | } |
| 99 | Ok(tasks) |
| 100 | } |
| 101 | |
| 102 | pub(super) fn convert_one( |
| 103 | plan: &SqlPlan, |