feat: clean up excutions

src/Command/ExecuteCommand.php

@@ -141,6 +141,40 @@ protected function execute(InputInterface $input, OutputInterface $output): int
         $this->entityManager->flush($execution);
         $this->eventDispatcher->dispatch(new CronFinishEvent($cronJob), CronFinishEvent::NAME);
 
+
+        // cleanup Executions
+        foreach ($cronJob->getExecutionRetention() as $state  => $maxRetained) {
+            $expr = $this->entityManager->getExpressionBuilder();
+
+            $topIds =  $this->entityManager->getRepository(Execution::class)->createQueryBuilder('execution')
+                ->select('execution.id')
+                ->where('execution.job = :jobClass')
+                ->andWhere('execution.state = :state')
+                ->orderBy('execution.startedAt', 'DESC')
+                ->setMaxResults($maxRetained)
+                ->setParameter('jobClass', $cronJob::class)
+                ->setParameter('state', $state)
+                ->getQuery()
+                ->getScalarResult();
+
+            if (empty($topIds)) {
+                continue;
+            }
+
+            $topIds = array_map(fn($item) => $item['id'], $topIds);
+
+            $this->entityManager->getRepository(Execution::class)->createQueryBuilder('execution')
+                ->delete()
+                ->where('execution.job = :jobClass')
+                ->andWhere('execution.state = :state')
+                ->andWhere('execution.id NOT IN (:topIds)')
+                ->setParameter('jobClass', $cronJob::class)
+                ->setParameter('state', $state)
+                ->setParameter('topIds', $topIds)
+                ->getQuery()
+                ->execute();
+        }
+
         return Command::SUCCESS;
     }
 

src/CronJob/AbstractCronJob.php

@@ -29,6 +29,7 @@
 
 namespace whatwedo\CronBundle\CronJob;
 
+use whatwedo\CronBundle\Entity\Execution;
 use whatwedo\CronBundle\Manager\CronJobManager;
 
 abstract class AbstractCronJob implements CronJobInterface
@@ -78,4 +79,14 @@ public function isActive(): bool
     {
         return true;
     }
+
+    public function getExecutionRetention(): array
+    {
+        return [
+            Execution::STATE_ERROR => 10,
+            Execution::STATE_FINISHED => 10,
+            Execution::STATE_STALE => 10,
+            Execution::STATE_TERMINATED => 10,
+        ];
+    }
 }

src/CronJob/CronInterface.php

@@ -53,4 +53,6 @@ public function isParallelAllowed(): bool;
      * Returns if the Job is enabled or not.
      */
     public function isActive(): bool;
+
+    public function getExecutionRetention(): array;
 }