fix decompress buf

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

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