From 920d27ebc1dccb5e86da9c1f8dfe012456dc32a0 Mon Sep 17 00:00:00 2001 From: Gareth Date: Wed, 12 Mar 2025 23:10:54 -0700 Subject: [PATCH] fix: index snapshots incorrectly creates duplicate entries for snapshots from other instances (#693) --- internal/orchestrator/tasks/taskindexsnapshots.go | 3 +-- 1 file changed, 1 insertion(+), 2 deletions(-) diff --git a/internal/orchestrator/tasks/taskindexsnapshots.go b/internal/orchestrator/tasks/taskindexsnapshots.go index 1f52fb81..0380c9a8 100644 --- a/internal/orchestrator/tasks/taskindexsnapshots.go +++ b/internal/orchestrator/tasks/taskindexsnapshots.go @@ -144,8 +144,7 @@ func indexCurrentSnapshotIdsForRepo(taskRunner TaskRunner, repoGUID string) (map startTime := time.Now() if err := taskRunner.QueryOperations(oplog.Query{}. - SetRepoGUID(repoGUID). - SetInstanceID(taskRunner.InstanceID()), + SetRepoGUID(repoGUID), func(op *v1.Operation) error { if snapshotOp, ok := op.Op.(*v1.Operation_OperationIndexSnapshot); ok { if !snapshotOp.OperationIndexSnapshot.Forgot {