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 {