Close rows on batch insert to avoid timeout issues. Releasing v0.9.0

inklabs · May 3, 2021 · d19653d · d19653d
1 parent 85c349c
commit d19653d
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 1 deletion.
diff --git a/provider/postgresstore/postgres_store.go b/provider/postgresstore/postgres_store.go
@@ -401,6 +401,7 @@ func (s *postgresStore) batchInsert(ctx context.Context, transaction dbQueryable
 	if err != nil {
 		return nil, 0, fmt.Errorf("unable to insert: %v", err)
 	}
+	defer ignoreClose(rows)
 
 	var globalSequenceNumbers []uint64
 	if !s.pgNotifyIsEnabled {

diff --git a/store.go b/store.go
@@ -8,7 +8,7 @@ import (
 )
 
 // Version for RangeDB.
-const Version = "0.9.0-dev"
+const Version = "0.9.0"
 
 // Record contains event data and metadata.
 type Record struct {