Skip to content

Commit

Permalink
Fix for #2867 (#2868)
Browse files Browse the repository at this point in the history
  • Loading branch information
magaton authored and conker84 committed May 18, 2022
1 parent aab8cff commit c2bac1b
Showing 1 changed file with 3 additions and 2 deletions.
5 changes: 3 additions & 2 deletions core/src/main/java/apoc/periodic/Periodic.java
Original file line number Diff line number Diff line change
Expand Up @@ -276,8 +276,9 @@ public Stream<BatchAndTotalResult> iterate(
String innerStatement = applyPlanner(prepared.first(), Planner.valueOf((String) config.getOrDefault("planner", Planner.DEFAULT.name())));
boolean iterateList = prepared.other();
String periodicId = UUID.randomUUID().toString();
log.info("Starting periodic iterate from `%s` operation using iteration `%s` in separate thread with id: `%s`", cypherIterate,cypherAction, periodicId);
log.info("starting batching from `%s` operation using iteration `%s` in separate thread", cypherIterate,cypherAction);
if (log.isDebugEnabled()) {
log.debug("Starting periodic iterate from `%s` operation using iteration `%s` in separate thread with id: `%s`", cypherIterate,cypherAction, periodicId);
}
return PeriodicUtils.iterateAndExecuteBatchedInSeparateThread(
db, terminationGuard, log, pools,
(int)batchSize, parallel, iterateList, retries, result,
Expand Down

0 comments on commit c2bac1b

Please sign in to comment.