mz_adapter::continual_task

Function ct_item_from_plan

Source 
pub fn ct_item_from_plan(
    plan: CreateContinualTaskPlan,
    output_id: GlobalId,
    resolved_ids: ResolvedIds,
) -> Result<ContinualTask, AdapterError>