add missing Rows.close()

authzed · Jul 11, 2023 · 95cd99f · 95cd99f
1 parent 6b28804
commit 95cd99f
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/internal/datastore/postgres/watch.go b/internal/datastore/postgres/watch.go
@@ -196,6 +196,8 @@ func (pgd *pgDatastore) loadChanges(ctx context.Context, revisions []revisionWit
 		return nil, fmt.Errorf("unable to load changes for XID: %w", err)
 	}
 
+	defer changes.Close()
+
 	tracked := common.NewChanges(revisionKeyFunc)
 	for changes.Next() {
 		nextTuple := &core.RelationTuple{