Skip to content

Commit f5e0ba9

Browse files
committed
Refactor exporter
1 parent 08266df commit f5e0ba9

File tree

1 file changed

+4
-3
lines changed

1 file changed

+4
-3
lines changed

export/exporter.go

Lines changed: 4 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -72,6 +72,7 @@ func (s *Exporter[T]) Export(ctx context.Context) (int64, error) {
7272
return 0, err
7373
}
7474
defer cursor.Close(ctx)
75+
defer s.Close()
7576
var i int64
7677
i = 0
7778
for cursor.Next(ctx) {
@@ -80,9 +81,9 @@ func (s *Exporter[T]) Export(ctx context.Context) (int64, error) {
8081
if err != nil {
8182
return i, err
8283
}
83-
err1 := s.TransformAndWrite(ctx, s.Write, &obj)
84-
if err1 != nil {
85-
return i, err1
84+
er2 := s.TransformAndWrite(ctx, s.Write, &obj)
85+
if er2 != nil {
86+
return i, er2
8687
}
8788
i = i + 1
8889
}

0 commit comments

Comments
 (0)