Skip to content

Commit

Permalink
fixup! backfill: implement loop
Browse files Browse the repository at this point in the history
Signed-off-by: Sumner Evans <sumner@beeper.com>
  • Loading branch information
sumnerevans committed Aug 3, 2023
1 parent 7c6eb04 commit f3585d2
Showing 1 changed file with 1 addition and 1 deletion.
2 changes: 1 addition & 1 deletion backfillqueue.go
Original file line number Diff line number Diff line change
Expand Up @@ -88,7 +88,7 @@ func (user *User) EnqueueBackfills(txn dbutil.Execable, priority, numPortals int
startDate = &startDaysAgo
}
priority := (stageIdx+1)*numPortals + priority
backfillMessages := user.bridge.DB.Backfill.NewWithValues(user.MXID, priority, portal.GUID, startDate, earliestBridgedTimestamp, backfillStage.MaxBatchEvents, -1, backfillStage.BatchDelay)
backfillMessages := user.bridge.DB.Backfill.NewWithValues(user.MXID, priority, portal.GUID, startDate, nil, backfillStage.MaxBatchEvents, -1, backfillStage.BatchDelay)
backfillMessages.Insert(txn)
}
}
Expand Down

0 comments on commit f3585d2

Please sign in to comment.