From 52c62cb26626c057d2ae2ebdc90164b95c847923 Mon Sep 17 00:00:00 2001 From: aceld Date: Wed, 3 Apr 2024 20:26:52 +0800 Subject: [PATCH] update --- test/caas/caas_demo1.go | 2 +- test/caas/caas_init1.go | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/test/caas/caas_demo1.go b/test/caas/caas_demo1.go index 4abdcae..d4c978c 100644 --- a/test/caas/caas_demo1.go +++ b/test/caas/caas_demo1.go @@ -6,7 +6,7 @@ import ( "github.com/aceld/kis-flow/kis" ) -// type CaaS func(context.Context, Connector, Function, Flow, interface{}) error +// type CaaS func(context.Context, Connector, Function, Flow, interface{}) (interface{}, error) func CaasDemoHanler1(ctx context.Context, conn kis.Connector, fn kis.Function, flow kis.Flow, args interface{}) (interface{}, error) { fmt.Printf("===> In CaasDemoHanler1: flowName: %s, cName:%s, fnName:%s, mode:%s\n", diff --git a/test/caas/caas_init1.go b/test/caas/caas_init1.go index 0ba141e..c600323 100644 --- a/test/caas/caas_init1.go +++ b/test/caas/caas_init1.go @@ -14,7 +14,7 @@ func InitConnDemo1(connector kis.Connector) error { fmt.Println(connConf) - // init connector , 如 初始化数据库链接等 + // init connector return nil }