diff --git a/src/Plugin/QueueWorker/FixityCheckWorker.php b/src/Plugin/QueueWorker/FixityCheckWorker.php index 04ad274..2bc09b5 100644 --- a/src/Plugin/QueueWorker/FixityCheckWorker.php +++ b/src/Plugin/QueueWorker/FixityCheckWorker.php @@ -60,13 +60,8 @@ class FixityCheckWorker extends QueueWorkerBase implements ContainerFactoryPlugi */ public function processItem($data) { if ($data instanceof FixityCheckInterface) { - if (empty($data->getFile())) { - $data->delete(); - } - else { - /** @var \Drupal\dgi_fixity\FixityCheckInterface $data */ - $this->fixity->check($data->getFile()); - } + /** @var \Drupal\dgi_fixity\FixityCheckInterface $data */ + $this->fixity->check($data->getFile()); } }