src/EventsSubscriber/Worker/WorkerHeartbeatSubscriber.php line 20

Open in your IDE?
  1. <?php
  3. declare(strict_types=1);
  5. namespace App\EventsSubscriber\Worker;
  7. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  8. use Symfony\Component\Messenger\Event\WorkerRunningEvent;
  10. /**
  11.  * Writes a heartbeat file on every messenger worker loop (WorkerRunningEvent fires each iteration,
  12.  * even when the worker is idle). The scheduler container's ECS health check reads this file's mtime,
  13.  * so a HUNG-but-running consumer (running != consuming — the failure mode behind the silent scheduler
  14.  * outages) goes stale and ECS replaces the task instead of leaving it wedged.
  15.  */
  16. class WorkerHeartbeatSubscriber implements EventSubscriberInterface
  17. {
  18.     public const HEARTBEAT_FILE = '/tmp/worker-heartbeat';
  20.     public function onWorkerRunning(WorkerRunningEvent $event): void
  21.     {
  22.         @touch(self::HEARTBEAT_FILE);
  23.     }
  25.     public static function getSubscribedEvents(): array
  26.     {
  27.         return [
  28.             WorkerRunningEvent::class => 'onWorkerRunning',
  29.         ];
  30.     }
  31. }