larryh/corso
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

DQ logs

Browse Source
This commit is contained in:
Abhishek Pandey 2023-08-16 19:01:14 +05:30
parent 838288ea13
commit f785e588ab
1 changed files with 2 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
src/internal/m365/collection/drive/item_collector.go
View File

@ -75,6 +75,7 @@ func collectItems(
pager.SetNext(prevDelta) pager.SetNext(prevDelta)
} }
logger.Ctx(ctx).Info("delta query iteration begin")
for { for {
// assume delta urls here, which allows single-token consumption // assume delta urls here, which allows single-token consumption
page, err := pager.GetPage(graph.ConsumeNTokens(ctx, graph.SingleGetOrDeltaLC)) page, err := pager.GetPage(graph.ConsumeNTokens(ctx, graph.SingleGetOrDeltaLC))
@ -128,6 +129,7 @@ func collectItems(
logger.Ctx(ctx).Debugw("Found nextLink", "link", nextLink) logger.Ctx(ctx).Debugw("Found nextLink", "link", nextLink)
pager.SetNext(nextLink) pager.SetNext(nextLink)
} }
logger.Ctx(ctx).Info("delta query iteration end")
return DeltaUpdate{URL: newDeltaURL, Reset: invalidPrevDelta}, newPaths, excluded, nil return DeltaUpdate{URL: newDeltaURL, Reset: invalidPrevDelta}, newPaths, excluded, nil
} }