@@ -199,7 +199,7 @@ class FeedsScheduler implements FeedsSchedulerInterface {
...
@@ -199,7 +199,7 @@ class FeedsScheduler implements FeedsSchedulerInterface {
db_query("UPDATE {feeds_schedule} SET scheduled = %d WHERE id = '%s' AND feed_nid = %d AND callback = '%s'",FEEDS_REQUEST_TIME,$job['id'],$job['feed_nid'],$job['callback']);
db_query("UPDATE {feeds_schedule} SET scheduled = %d WHERE id = '%s' AND feed_nid = %d AND callback = '%s'",FEEDS_REQUEST_TIME,$job['id'],$job['feed_nid'],$job['callback']);
if(db_affected_rows()){
if(db_affected_rows()){
if($this->queue()){
if($this->queue()){
if(!$queue->createItem($job)){
if(!$this->queue()->createItem($job)){
$this->unschedule($job);
$this->unschedule($job);
watchdog('FeedsScheduler','Error adding item to queue.',WATCHDOG_CRITICAL);
watchdog('FeedsScheduler','Error adding item to queue.',WATCHDOG_CRITICAL);