Fix a bug where the delete worker wasn't iterating over schedules
This commit is contained in:
parent
9fc46710c5
commit
c7492ee35e
1 changed files with 11 additions and 1 deletions
|
@ -679,16 +679,26 @@ class DeletesV1 extends Worker
|
||||||
$limit = 50;
|
$limit = 50;
|
||||||
$results = [];
|
$results = [];
|
||||||
$sum = $limit;
|
$sum = $limit;
|
||||||
|
$cursor = null;
|
||||||
|
|
||||||
$executionStart = \microtime(true);
|
$executionStart = \microtime(true);
|
||||||
|
|
||||||
while ($sum === $limit) {
|
while ($sum === $limit) {
|
||||||
$chunk++;
|
$chunk++;
|
||||||
|
|
||||||
$results = $database->find($collection, \array_merge([Query::limit($limit)], $queries));
|
$mergedQueries = \array_merge([Query::limit($limit)], $queries);
|
||||||
|
if ($cursor instanceof Document) {
|
||||||
|
$mergedQueries[] = Query::cursorAfter($cursor);
|
||||||
|
}
|
||||||
|
|
||||||
|
$results = $database->find($collection, $mergedQueries);
|
||||||
|
|
||||||
$sum = count($results);
|
$sum = count($results);
|
||||||
|
|
||||||
|
if ($sum > 0) {
|
||||||
|
$cursor = $results[$sum - 1];
|
||||||
|
}
|
||||||
|
|
||||||
foreach ($results as $document) {
|
foreach ($results as $document) {
|
||||||
if (is_callable($callback)) {
|
if (is_callable($callback)) {
|
||||||
$callback($document);
|
$callback($document);
|
||||||
|
|
Loading…
Reference in a new issue