From 07f0d8836a8425cc2bdbb79f2db5b17832b3667c Mon Sep 17 00:00:00 2001 From: Nick Mills-Barrett Date: Wed, 5 Mar 2025 10:46:06 +0000 Subject: [PATCH] bridgev2/backfillqueue: expose `DoBackfillTask` method --- bridgev2/backfillqueue.go | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/bridgev2/backfillqueue.go b/bridgev2/backfillqueue.go index 7d521fd1..61318d94 100644 --- a/bridgev2/backfillqueue.go +++ b/bridgev2/backfillqueue.go @@ -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)).