diff --git a/src/Bundle/ChillMainBundle/Service/Workflow/CancelStaleWorkflow.php b/src/Bundle/ChillMainBundle/Service/Workflow/CancelStaleWorkflow.php
new file mode 100644
index 000000000..d13ca039e
--- /dev/null
+++ b/src/Bundle/ChillMainBundle/Service/Workflow/CancelStaleWorkflow.php
@@ -0,0 +1,15 @@
+<?php
+
+namespace Chill\MainBundle\Service\Workflow;
+
+class CancelStaleWorkflow
+{
+    public function __construct(public array $workflowIds)
+    {
+    }
+
+    public function getWorkflowIds(): array
+    {
+        return $this->workflowIds;
+    }
+}
diff --git a/src/Bundle/ChillMainBundle/Service/Workflow/CancelStaleWorkflowHandler.php b/src/Bundle/ChillMainBundle/Service/Workflow/CancelStaleWorkflowHandler.php
new file mode 100644
index 000000000..aff22d1e3
--- /dev/null
+++ b/src/Bundle/ChillMainBundle/Service/Workflow/CancelStaleWorkflowHandler.php
@@ -0,0 +1,30 @@
+<?php
+
+namespace Chill\MainBundle\Service\Workflow;
+
+use Chill\MainBundle\Repository\Workflow\EntityWorkflowRepository;
+use Doctrine\ORM\EntityManagerInterface;
+use Psr\Log\LoggerInterface;
+use Symfony\Component\Messenger\Handler\MessageHandlerInterface;
+
+class CancelStaleWorkflowHandler implements MessageHandlerInterface
+{
+    public function __construct(private readonly EntityWorkflowRepository $workflowRepository, private EntityManagerInterface $em, private LoggerInterface $logger)
+    {
+
+    }
+
+    public function __invoke(CancelStaleWorkflow $message): void
+    {
+        $workflowIds = $message->getWorkflowIds();
+
+        foreach ($workflowIds as $workflowId) {
+            $workflow = $this->workflowRepository->find($workflowId);
+
+            $steps = $workflow->getSteps();
+
+
+        }
+    }
+
+}