diff --git a/modules/labelmsg/redismsgsender.go b/modules/labelmsg/redismsgsender.go
index 8b2eae772..c06407588 100644
--- a/modules/labelmsg/redismsgsender.go
+++ b/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)