aboutsummaryrefslogtreecommitdiff
path: root/syncapi/streams/stream_accountdata.go
diff options
context:
space:
mode:
Diffstat (limited to 'syncapi/streams/stream_accountdata.go')
-rw-r--r--syncapi/streams/stream_accountdata.go1
1 files changed, 1 insertions, 0 deletions
diff --git a/syncapi/streams/stream_accountdata.go b/syncapi/streams/stream_accountdata.go
index 3f2f7d13..34135d65 100644
--- a/syncapi/streams/stream_accountdata.go
+++ b/syncapi/streams/stream_accountdata.go
@@ -54,6 +54,7 @@ func (p *AccountDataStreamProvider) IncrementalSync(
)
if err != nil {
req.Log.WithError(err).Error("p.DB.GetAccountDataInRange failed")
+ _ = snapshot.Rollback()
return from
}