From f306b2d025ee4ca47f7ae455dc66bb72a82b4992 Mon Sep 17 00:00:00 2001 From: yuyuanshifu <747342561@qq.com> Date: Tue, 26 Jan 2021 15:20:50 +0800 Subject: [PATCH] fix decompress buf --- modules/timer/timer.go | 16 ++++++++-------- modules/worker/task.go | 2 +- 2 files changed, 9 insertions(+), 9 deletions(-) diff --git a/modules/timer/timer.go b/modules/timer/timer.go index 60aaa7498..a501234d1 100755 --- a/modules/timer/timer.go +++ b/modules/timer/timer.go @@ -12,16 +12,16 @@ func init() { spec := "*/10 * * * *" c.AddFunc(spec, repo.HandleUnDecompressAttachment) - specCheckBlockChainUserSuccess := "*/10 * * * *" - c.AddFunc(specCheckBlockChainUserSuccess, repo.HandleBlockChainUnSuccessUsers) + //specCheckBlockChainUserSuccess := "*/10 * * * *" + //c.AddFunc(specCheckBlockChainUserSuccess, repo.HandleBlockChainUnSuccessUsers) - specCheckRepoBlockChainSuccess := "*/5 * * * *" - c.AddFunc(specCheckRepoBlockChainSuccess, repo.HandleBlockChainUnSuccessRepos) + //specCheckRepoBlockChainSuccess := "*/5 * * * *" + //c.AddFunc(specCheckRepoBlockChainSuccess, repo.HandleBlockChainUnSuccessRepos) - specCheckUnTransformedActions := "*/1 * * * *" - c.AddFunc(specCheckUnTransformedActions, repo.HandleUnTransformedActions) + //specCheckUnTransformedActions := "*/1 * * * *" + //c.AddFunc(specCheckUnTransformedActions, repo.HandleUnTransformedActions) - specCheckBlockChainCommitSuccess := "*/3 * * * *" - c.AddFunc(specCheckBlockChainCommitSuccess, repo.HandleBlockChainUnSuccessCommits) + //specCheckBlockChainCommitSuccess := "*/3 * * * *" + //c.AddFunc(specCheckBlockChainCommitSuccess, repo.HandleBlockChainUnSuccessCommits) c.Start() } diff --git a/modules/worker/task.go b/modules/worker/task.go index 48ba32c3e..073b16b92 100755 --- a/modules/worker/task.go +++ b/modules/worker/task.go @@ -14,7 +14,7 @@ const ( ) func SendDecompressTask(ctx context.Context, uuid string) error { - args := []tasks.Arg{{Name: "uuid", Type: "string", Value: uuid},{}} + args := []tasks.Arg{{Name: "uuid", Type: "string", Value: uuid}} task, err := tasks.NewSignature(DecompressTaskName, args) if err != nil { log.Error("NewSignature failed:", err.Error())