Fix paging

nlnwa · Apr 27, 2021 · 094e7c3 · 094e7c3
1 parent 5e871e1
commit 094e7c3
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/internal/scylla/logserver.go b/internal/scylla/logserver.go
@@ -333,6 +333,7 @@ func listPageLogsByExecutionId(query *gocqlx.Queryx, req *logV1.PageLogListReque
 	iter := query.BindMap(qb.M{"execution_id": executionId}).Iter()
 	for pageLog := new(PageLog); iter.StructScan(pageLog); pageLog = new(PageLog) {
 		if count < offset {
+			count++
 			continue
 		}
 		err := fn(pageLog.toProto())
@@ -388,6 +389,7 @@ func listCrawlLogsByExecutionId(query *gocqlx.Queryx, req *logV1.CrawlLogListReq
 	iter := query.BindMap(qb.M{"execution_id": executionId}).Iter()
 	for crawlLog := new(CrawlLog); iter.StructScan(crawlLog); crawlLog = new(CrawlLog) {
 		if count < offset {
+			count++
 			continue
 		}
 		err := fn(crawlLog.toProto())