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