bridgev2/backfillqueue: expose DoBackfillTask method

This commit is contained in:
Nick Mills-Barrett 2025-03-05 10:46:06 +00:00
commit 07f0d8836a
No known key found for this signature in database
GPG key ID: 31F23F2CF354937B

View file

@ -80,13 +80,13 @@ func (br *Bridge) RunBackfillQueue() {
time.Sleep(BackfillQueueErrorBackoff)
continue
} else if backfillTask != nil {
br.doBackfillTask(ctx, backfillTask)
br.DoBackfillTask(ctx, backfillTask)
noTasksFoundCount = 0
}
}
}
func (br *Bridge) doBackfillTask(ctx context.Context, task *database.BackfillTask) {
func (br *Bridge) DoBackfillTask(ctx context.Context, task *database.BackfillTask) {
log := zerolog.Ctx(ctx).With().
Object("portal_key", task.PortalKey).
Str("login_id", string(task.UserLoginID)).