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())