From a16e4f4dc7c39e9d7784c9e1d3b81ebbd72f45fd Mon Sep 17 00:00:00 2001 From: "Mr. Lan" Date: Fri, 17 Jul 2020 01:21:48 +0800 Subject: [PATCH] =?UTF-8?q?=E6=B7=BB=E5=8A=A0=E6=B5=81=E7=A8=8B=E7=94=B3?= =?UTF-8?q?=E8=AF=B7=E3=80=82?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- apis/process/workOrder.go | 1 - pkg/task/server.go | 5 +++-- 2 files changed, 3 insertions(+), 3 deletions(-) diff --git a/apis/process/workOrder.go b/apis/process/workOrder.go index 3cd0e0ae..40430352 100644 --- a/apis/process/workOrder.go +++ b/apis/process/workOrder.go @@ -6,7 +6,6 @@ import ( "ferry/global/orm" "ferry/models/process" "ferry/models/system" - . "ferry/pkg/response/response" "ferry/pkg/service" "ferry/tools" "ferry/tools/app" diff --git a/pkg/task/server.go b/pkg/task/server.go index 0ff8812d..4ced886f 100644 --- a/pkg/task/server.go +++ b/pkg/task/server.go @@ -5,8 +5,9 @@ package task */ import ( - "ferry/pkg/logger" "ferry/pkg/task/worker" + + "github.com/RichardKnop/machinery/v1/log" ) func Start() { @@ -14,6 +15,6 @@ func Start() { taskWorker := worker.NewAsyncTaskWorker(0) err := taskWorker.Launch() if err != nil { - logger.Errorf("启动machinery失败,%v", err.Error()) + log.ERROR.Println("启动machinery失败,%v", err.Error()) } }