From 6c286be01a889e3b3276f3b6a48f2d78caeb4f8c Mon Sep 17 00:00:00 2001 From: WenyXu Date: Mon, 29 Apr 2024 10:02:02 +0000 Subject: [PATCH] feat: register the procedure --- src/common/meta/src/ddl_manager.rs | 9 +++++++++ 1 file changed, 9 insertions(+) diff --git a/src/common/meta/src/ddl_manager.rs b/src/common/meta/src/ddl_manager.rs index 313f193ff2c6..2f3d3a4eb45c 100644 --- a/src/common/meta/src/ddl_manager.rs +++ b/src/common/meta/src/ddl_manager.rs @@ -115,6 +115,15 @@ impl DdlManager { }) }, ), + ( + CreateFlowProcedure::TYPE_NAME, + &|context: DdlContext| -> BoxedProcedureLoader { + Box::new(move |json: &str| { + let context = context.clone(); + CreateFlowProcedure::from_json(json, context).map(|p| Box::new(p) as _) + }) + }, + ), ( AlterTableProcedure::TYPE_NAME, &|context: DdlContext| -> BoxedProcedureLoader {