github_mirrors/kis-flow
1
0
Fork 0
mirror of https://github.com/aceld/kis-flow.git synced 2025-02-02 15:28:38 +08:00
Code Issues Packages Projects Releases Wiki Activity

change some output Info->Debug

Browse Source
This commit is contained in:
aceld 2024-03-26 15:59:48 +08:00
parent 852fb68d43
commit 6d34cb7d6c
4 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
function/kis_function_e.go
View File

@ -20,7 +20,7 @@ func NewKisFunctionE() kis.Function {
}
func (f *KisFunctionE) Call(ctx context.Context, flow kis.Flow) error {
log.Logger().InfoF("KisFunctionE, flow = %+v\n", flow)
log.Logger().DebugF("KisFunctionE, flow = %+v\n", flow)
// 通过KisPool 路由到具体的执行计算Function中
if err := kis.Pool().CallFunction(ctx, f.Config.FName, flow); err != nil {

2
function/kis_function_l.go
View File

@ -20,7 +20,7 @@ func NewKisFunctionL() kis.Function {
}
func (f *KisFunctionL) Call(ctx context.Context, flow kis.Flow) error {
log.Logger().InfoF("KisFunctionL, flow = %+v\n", flow)
log.Logger().DebugF("KisFunctionL, flow = %+v\n", flow)
// 通过KisPool 路由到具体的执行计算Function中
if err := kis.Pool().CallFunction(ctx, f.Config.FName, flow); err != nil {

2
function/kis_function_s.go
View File

@ -20,7 +20,7 @@ func NewKisFunctionS() kis.Function {
}
func (f *KisFunctionS) Call(ctx context.Context, flow kis.Flow) error {
log.Logger().InfoF("KisFunctionS, flow = %+v\n", flow)
log.Logger().DebugF("KisFunctionS, flow = %+v\n", flow)
// 通过KisPool 路由到具体的执行计算Function中
if err := kis.Pool().CallFunction(ctx, f.Config.FName, flow); err != nil {

2
function/kis_function_v.go
View File

@ -20,7 +20,7 @@ func NewKisFunctionV() kis.Function {
}
func (f *KisFunctionV) Call(ctx context.Context, flow kis.Flow) error {
log.Logger().InfoF("KisFunctionV, flow = %+v\n", flow)
log.Logger().DebugF("KisFunctionV, flow = %+v\n", flow)
// 通过KisPool 路由到具体的执行计算Function中
if err := kis.Pool().CallFunction(ctx, f.Config.FName, flow); err != nil {