修改状态

Signed-off-by: zouap <zouap@pcl.ac.cn>

modules/labelmsg/redismsgsender.go

@@ -50,6 +50,7 @@ func SendDecompressAttachToLabelOBS(attach string) error {
 	_, err := redisclient.Do("Publish", setting.DecompressOBSTaskName, attach)
 	if err != nil {
 		log.Critical("redis Publish failed.")
+		return err
 	}
 
 	log.Info("LabelDecompressOBSQueue(%s) success", attach)