|
|
@@ -198,7 +198,7 @@ func (that *ProjectBackfeedManager) Do() { |
|
|
|
try := 0 |
|
|
|
for { |
|
|
|
if err := that.ProjectRedis.SAdd(context.Background(), fmt.Sprintf("%s:%s", that.Name, queue), sAddItems...).Err(); err != nil { |
|
|
|
log.Printf("failed to sadd items for %s: %s", that.Name, err) |
|
|
|
log.Printf("failed to sadd items for %s:%s: %s", that.Name, queue, err) |
|
|
|
time.Sleep(time.Duration(try) * time.Second) |
|
|
|
try++ |
|
|
|
} else { |
|
|
|