Skip to content

Commit

Permalink
Fix linter errors
Browse files Browse the repository at this point in the history
Lines are unchanged, not sure why flagged now
  • Loading branch information
AndrewSisley committed Feb 2, 2022
1 parent 2c3d335 commit b93bc96
Show file tree
Hide file tree
Showing 2 changed files with 9 additions and 4 deletions.
6 changes: 3 additions & 3 deletions db/collection_update.go
Original file line number Diff line number Diff line change
Expand Up @@ -252,7 +252,7 @@ func (c *Collection) updateWithFilter(ctx context.Context, txn *Txn, filter inte
if err != nil {
return nil, err
}
if err := query.Start(); err != nil {
if err = query.Start(); err != nil {
return nil, err
}

Expand All @@ -262,8 +262,8 @@ func (c *Collection) updateWithFilter(ctx context.Context, txn *Txn, filter inte

// loop while we still have results from the filter query
for {
next, err := query.Next()
if err != nil {
next, nextErr := query.Next()
if nextErr != nil {
return nil, err
}
// if theres no more records from the query, jump out of the loop
Expand Down
7 changes: 6 additions & 1 deletion db/fetcher/fetcher.go
Original file line number Diff line number Diff line change
Expand Up @@ -384,6 +384,11 @@ func (df *DocumentFetcher) Close() error {
if df.kvIter == nil {
return nil
}
df.kvIter.Close()

err := df.kvIter.Close()
if err != nil {
return err
}

return df.kvResultsIter.Close()
}

0 comments on commit b93bc96

Please sign in to comment.