createSampleNodes(); $feed = $this->createFeed(); $count_query = \Drupal::entityQuery('aggregator_item')->condition('fid', $feed->id())->count(); $this->cronRun(); $this->assertEqual(5, $count_query->execute()); $this->deleteFeedItems($feed); $this->assertEqual(0, $count_query->execute()); $this->cronRun(); $this->assertEqual(5, $count_query->execute()); // Test feed locking when queued for update. $this->deleteFeedItems($feed); $feed->setQueuedTime(REQUEST_TIME)->save(); $this->cronRun(); $this->assertEqual(0, $count_query->execute()); $feed->setQueuedTime(0)->save(); $this->cronRun(); $this->assertEqual(5, $count_query->execute()); } }