WIP

Author: jeremycr

README.md

@@ -243,7 +243,6 @@ implementing `DataflowTypeInterface`.
 
 Otherwise, manually add the tag `coderhapsodie.dataflow.type` in your dataflow type service configuration:
 
-```yaml
 ```yaml
 CodeRhapsodie\DataflowExemple\DataflowType\MyFirstDataflowType:
   tags:

src/Command/JobCleanupCommand.php

@@ -0,0 +1,24 @@
+<?php
+
+declare(strict_types=1);
+
+namespace CodeRhapsodie\DataflowBundle\Command;
+
+use Symfony\Component\Console\Attribute\AsCommand;
+use Symfony\Component\Console\Command\Command;
+use Symfony\Component\Console\Input\InputInterface;
+use Symfony\Component\Console\Output\OutputInterface;
+
+#[AsCommand(name: 'code-rhapsodie:job_cleanup', description: 'Cleanup job history.')]
+class JobCleanupCommand extends Command
+{
+    protected function configure()
+    {
+        $this->setHelp('Job retention can be configured with the "job_history_retention" configuration.');
+    }
+
+    protected function execute(InputInterface $input, OutputInterface $output): int
+    {
+
+    }
+}

src/DependencyInjection/Configuration.php

@@ -52,6 +52,20 @@ public function getConfigTreeBuilder(): TreeBuilder
                         ->thenInvalid('You need "league/flysystem" to use Dataflow file exception mode.')
                     ->end()
                 ->end()
+                ->arrayNode('job_history')
+                    ->addDefaultsIfNotSet()
+                    ->children()
+                        ->integerNode('retention')
+                            ->defaultValue(30)
+                            ->min(0)
+                            ->info('How many days completed jobs are kept when running the cleanup command.')
+                        ->end()
+                        ->integerNode('forceful_completion_delay')
+                            ->defaultValue(24)
+                            ->min(24)
+                            ->info('Running jobs will be forcefully set as completed after this many full calendar days when running the cleanup command.')
+                        ->end()
+                    ->end()
             ->end()
         ;