diff --git a/plugins/FeedsNodeProcessor.inc b/plugins/FeedsNodeProcessor.inc index c369bf96fae3395fcb331d4f77c3ee67b2972db6..5f2a8d2bb8133326c2f4a1f048928f7935145034 100644 --- a/plugins/FeedsNodeProcessor.inc +++ b/plugins/FeedsNodeProcessor.inc @@ -123,9 +123,11 @@ class FeedsNodeProcessor extends FeedsProcessor { } $count = $this->getLimit(); $nodes = db_query_range("SELECT n.nid FROM {node} n JOIN {feeds_node_item} fni ON n.nid = fni.nid WHERE fni.id = :id AND n.created < :created", 0, $count, array(':id' => $this->id, ':created' => REQUEST_TIME - $time)); + $nids = array(); foreach ($nodes as $node) { - _feeds_node_delete($node->nid); + $nids[$node->nid] = $node->nid; } + node_delete_multiple($nids); if (db_query_range("SELECT 1 FROM {node} n JOIN {feeds_node_item} fni ON n.nid = fni.nid WHERE fni.id = :id AND n.created < :created", 0, 1, array(':id' => $this->id, ':created' => REQUEST_TIME - $time))->fetchField()) { return FEEDS_BATCH_ACTIVE; }