$w->autoJoin();
- $ar = $w->fetchAll();
+ $ar = array(); // $w->fetchAll();
if (!empty($opts['list'])) {
if (empty($ar)) {
$pushed = array();
$requeue = array();
while (true) {
-
+ if ($w->fetch()) {
+ $ar[] = clone($w);
+ }
$this->logecho("BATCH SIZE: ". count($ar) );