linter

conduitio-labs · Aug 31, 2023 · 9eb824f · 9eb824f
1 parent 820dffb
commit 9eb824f
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 0 deletions.
diff --git a/columntypes/columntypes.go b/columntypes/columntypes.go
@@ -57,6 +57,7 @@ func GetColumnTypes(ctx context.Context, db *sqlx.DB, table, schema string) (map
 	if err != nil {
 		return nil, fmt.Errorf("select column types %q, %v: %w", query, args, err)
 	}
+	defer rows.Close()
 
 	columnTypes := make(map[string]string)
 	for rows.Next() {

diff --git a/source/iterator/iterator.go b/source/iterator/iterator.go
@@ -315,6 +315,7 @@ func (iter *Iterator) latestSnapshotValue(ctx context.Context) (any, error) {
 	if err != nil {
 		return nil, fmt.Errorf("execute select latest snapshot value query %q: %w", query, err)
 	}
+	defer rows.Close()
 
 	for rows.Next() {
 		if err = rows.Scan(&latestSnapshotValue); err != nil {