diff --git a/web/modules/custom/blog/src/Plugin/QueueWorker/PostPusherQueueWorker.php b/web/modules/custom/blog/src/Plugin/QueueWorker/PostPusherQueueWorker.php index f85503b3a..86c3e5473 100644 --- a/web/modules/custom/blog/src/Plugin/QueueWorker/PostPusherQueueWorker.php +++ b/web/modules/custom/blog/src/Plugin/QueueWorker/PostPusherQueueWorker.php @@ -17,6 +17,11 @@ use Drupal\opdavies_blog\Entity\Node\Post; final class PostPusherQueueWorker extends QueueWorkerBase { public function processItem($data): void { + ['post' => $post] = $data; + + if (!$this->shouldBePushed($post)) { + return; + } } private function shouldBePushed(Post $post): bool {