XinanXf/ferry
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

添加流程申请。

Browse Source
This commit is contained in:
Mr. Lan 2020-07-17 01:21:48 +08:00
parent 38cac4050c
commit a16e4f4dc7
2 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
apis/process/workOrder.go
View File

@ -6,7 +6,6 @@ import (
"ferry/global/orm" "ferry/global/orm"
"ferry/models/process" "ferry/models/process"
"ferry/models/system" "ferry/models/system"
. "ferry/pkg/response/response"
"ferry/pkg/service" "ferry/pkg/service"
"ferry/tools" "ferry/tools"
"ferry/tools/app" "ferry/tools/app"

5
pkg/task/server.go
View File

@ -5,8 +5,9 @@ package task
*/ */
import ( import (
"ferry/pkg/logger"
"ferry/pkg/task/worker" "ferry/pkg/task/worker"
"github.com/RichardKnop/machinery/v1/log"
) )
func Start() { func Start() {
@ -14,6 +15,6 @@ func Start() {
taskWorker := worker.NewAsyncTaskWorker(0) taskWorker := worker.NewAsyncTaskWorker(0)
err := taskWorker.Launch() err := taskWorker.Launch()
if err != nil { if err != nil {
logger.Errorf("启动machinery失败，%v", err.Error()) log.ERROR.Println("启动machinery失败，%v", err.Error())
} }
} }