@@ -211,7 +211,7 @@ function os2web_adlib_api_status() {
211
211
->condition(db_or()->condition('job_id', 'Complete', '!=')->isNull('job_id'))
212
212
->execute()
213
213
->fetchAll();
214
- $chunk_size = max(min((int) sqrt(count($items)), 25 ), 1);
214
+ $chunk_size = max(min((int) sqrt(count($items)), 5 ), 1);
215
215
$items = array_chunk($items, $chunk_size);
216
216
foreach ($items as $item) {
217
217
$batch['operations'][] = array('_os2web_adlib_api_process_fid', array($item));
@@ -298,15 +298,15 @@ function os2web_adlib_api_cron() {
298
298
_os2web_adlib_api_do_processing();
299
299
300
300
// Add set up queue for adlib requeueing.
301
- $queue = DrupalQueue::get('os2web_adlib_reprocess');
302
- if ($queue->numberOfItems() == 0) {
303
- $items = _os2web_adlib_api_bulletpoint_nid();
304
- $chunk_size = max(min((int) sqrt(count($items)), 25), 1);
305
- $items = array_chunk($items, $chunk_size);
306
- foreach ($items as $item) {
307
- $queue->createItem($item);
308
- }
309
- }
301
+ // $queue = DrupalQueue::get('os2web_adlib_reprocess');
302
+ // if ($queue->numberOfItems() == 0) {
303
+ // $items = _os2web_adlib_api_bulletpoint_nid();
304
+ // $chunk_size = max(min((int) sqrt(count($items)), 25), 1);
305
+ // $items = array_chunk($items, $chunk_size);
306
+ // foreach ($items as $item) {
307
+ // $queue->createItem($item);
308
+ // }
309
+ // }
310
310
}
311
311
312
312
/**
@@ -450,7 +450,7 @@ function _os2web_adlib_api_do_processing() {
450
450
->condition(db_or()->condition('job_id', 'Complete', '!=')->isNull('job_id'))
451
451
->execute()
452
452
->fetchAll();
453
- $chunk_size = max(min((int) sqrt(count($items)), 25 ), 1);
453
+ $chunk_size = max(min((int) sqrt(count($items)), 5 ), 1);
454
454
$items = array_chunk($items, $chunk_size);
455
455
foreach ($items as $item) {
456
456
if ($item->job_id != 'Complete') {
0 commit comments