common_meta::ddl_manager

Function handle_create_flow_task

source 
async fn handle_create_flow_task(
    ddl_manager: &DdlManager,
    cluster_id: ClusterId,
    create_flow_task: CreateFlowTask,
    query_context: QueryContext,
) -> Result<SubmitDdlTaskResponse>