Updated for PHP 8.2

jeremycr · jeremycr · commit 976cc8212328 · 2026-03-31T14:33:28.000+02:00
diff --git a/CHANGELOG.md b/CHANGELOG.md
@@ -1,5 +1,6 @@
 # Version 5.5.0
 * Added cleanup commands
+* Updated for PHP 8.2
 
 # Version 5.4.1
 * Fix File Exceptions integration
diff --git a/Tests/DataflowType/AbstractDataflowTypeTest.php b/Tests/DataflowType/AbstractDataflowTypeTest.php
@@ -18,7 +18,7 @@ public function testProcess()
 
         $dataflowType = new class($label, $options, $values, $testCase) extends AbstractDataflowType
         {
-            public function __construct(private string $label, private array $options, private array $values, private TestCase $testCase)
+            public function __construct(private readonly string $label, private readonly array $options, private readonly array $values, private readonly TestCase $testCase)
             {
             }
 
diff --git a/composer.json b/composer.json
@@ -41,7 +41,7 @@
         }
     },
     "require": {
-        "php": "^8.0",
+        "php": "^8.2",
         "ext-json": "*",
         "doctrine/dbal": "^3.0||^4.0",
         "doctrine/doctrine-bundle": "^2.0",
diff --git a/rector.php b/rector.php
@@ -7,19 +7,16 @@
 use Rector\Set\ValueObject\LevelSetList;
 use Rector\Symfony\Set\SymfonySetList;
 
-return static function (RectorConfig $rectorConfig): void {
-    $rectorConfig->paths([
-        __DIR__ . '/src',
-        __DIR__ . '/Tests',
-    ]);
-
-    // register a single rule
-    $rectorConfig->rule(InlineConstructorDefaultToPropertyRector::class);
-
-    $rectorConfig->sets([
-        SymfonySetList::SYMFONY_70,
+return RectorConfig::configure()
+    ->withPaths([
+        __DIR__.'/src',
+        __DIR__.'/Tests',
+    ])
+    ->withComposerBased(symfony: true)
+    ->withRules([InlineConstructorDefaultToPropertyRector::class])
+    ->withSets([
         SymfonySetList::SYMFONY_CODE_QUALITY,
         SymfonySetList::SYMFONY_CONSTRUCTOR_INJECTION,
-        LevelSetList::UP_TO_PHP_80,
-    ]);
-};
+        LevelSetList::UP_TO_PHP_82,
+    ])
+;
diff --git a/src/Command/AddScheduledDataflowCommand.php b/src/Command/AddScheduledDataflowCommand.php
@@ -19,18 +19,19 @@
 /**
  * @codeCoverageIgnore
  */
-#[AsCommand('code-rhapsodie:dataflow:schedule:add', 'Create a scheduled dataflow')]
+#[AsCommand('code-rhapsodie:dataflow:schedule:add', 'Create a scheduled dataflow', help: <<<'TXT'
+The <info>%command.name%</info> allows you to create a new scheduled dataflow.
+TXT)]
 class AddScheduledDataflowCommand extends Command
 {
-    public function __construct(private DataflowTypeRegistryInterface $registry, private ScheduledDataflowRepository $scheduledDataflowRepository, private ValidatorInterface $validator, private ConnectionFactory $connectionFactory)
+    public function __construct(private readonly DataflowTypeRegistryInterface $registry, private readonly ScheduledDataflowRepository $scheduledDataflowRepository, private readonly ValidatorInterface $validator, private readonly ConnectionFactory $connectionFactory)
     {
         parent::__construct();
     }
 
     protected function configure(): void
     {
         $this
-            ->setHelp('The <info>%command.name%</info> allows you to create a new scheduled dataflow.')
             ->addOption('label', null, InputOption::VALUE_REQUIRED, 'Label of the scheduled dataflow')
             ->addOption('type', null, InputOption::VALUE_REQUIRED, 'Type of the scheduled dataflow (FQCN)')
             ->addOption(
diff --git a/src/Command/ChangeScheduleStatusCommand.php b/src/Command/ChangeScheduleStatusCommand.php
@@ -18,18 +18,19 @@
 /**
  * @codeCoverageIgnore
  */
-#[AsCommand('code-rhapsodie:dataflow:schedule:change-status', 'Change schedule status')]
+#[AsCommand('code-rhapsodie:dataflow:schedule:change-status', 'Change schedule status', help: <<<'TXT'
+The <info>%command.name%</info> command able you to change schedule status.
+TXT)]
 class ChangeScheduleStatusCommand extends Command
 {
-    public function __construct(private ScheduledDataflowRepository $scheduledDataflowRepository, private ConnectionFactory $connectionFactory)
+    public function __construct(private readonly ScheduledDataflowRepository $scheduledDataflowRepository, private readonly ConnectionFactory $connectionFactory)
     {
         parent::__construct();
     }
 
     protected function configure(): void
     {
         $this
-            ->setHelp('The <info>%command.name%</info> command able you to change schedule status.')
             ->addArgument('schedule-id', InputArgument::REQUIRED, 'Id of the schedule')
             ->addOption('enable', null, InputOption::VALUE_NONE, 'Enable the schedule')
             ->addOption('disable', null, InputOption::VALUE_NONE, 'Disable the schedule')
diff --git a/src/Command/DatabaseSchemaCommand.php b/src/Command/DatabaseSchemaCommand.php
@@ -19,18 +19,19 @@
 use Symfony\Component\Console\Question\ConfirmationQuestion;
 use Symfony\Component\Console\Style\SymfonyStyle;
 
-#[AsCommand(name: 'code-rhapsodie:dataflow:database-schema', description: 'Generates schema create / update SQL queries')]
+#[AsCommand(name: 'code-rhapsodie:dataflow:database-schema', description: 'Generates schema create / update SQL queries', help: <<<'TXT'
+The <info>%command.name%</info> help you to generate SQL Query to create or update your database schema for this bundle
+TXT)]
 class DatabaseSchemaCommand extends Command
 {
-    public function __construct(private ConnectionFactory $connectionFactory)
+    public function __construct(private readonly ConnectionFactory $connectionFactory)
     {
         parent::__construct();
     }
 
     protected function configure(): void
     {
         $this
-            ->setHelp('The <info>%command.name%</info> help you to generate SQL Query to create or update your database schema for this bundle')
             ->addOption('dump-sql', null, InputOption::VALUE_NONE, 'Dump only the update SQL queries.')
             ->addOption('update', null, InputOption::VALUE_NONE, 'Dump/execute only the update SQL queries.')
             ->addOption('connection', null, InputOption::VALUE_REQUIRED, 'Define the DBAL connection to use');
diff --git a/src/Command/ExecuteDataflowCommand.php b/src/Command/ExecuteDataflowCommand.php
@@ -23,7 +23,11 @@
  *
  * @codeCoverageIgnore
  */
-#[AsCommand('code-rhapsodie:dataflow:execute', 'Runs one dataflow type with provided options')]
+#[AsCommand('code-rhapsodie:dataflow:execute', 'Runs one dataflow type with provided options', help: <<<'TXT'
+The <info>%command.name%</info> command runs one dataflow with the provided options.
+
+  <info>php %command.full_name% App\Dataflow\MyDataflow '{"option1": "value1", "option2": "value2"}'</info>
+TXT)]
 class ExecuteDataflowCommand extends Command implements LoggerAwareInterface
 {
     use LoggerAwareTrait;
@@ -36,13 +40,6 @@ public function __construct(private DataflowTypeRegistryInterface $registry, pri
     protected function configure(): void
     {
         $this
-            ->setHelp(
-                <<<'EOF'
-The <info>%command.name%</info> command runs one dataflow with the provided options.
-
-  <info>php %command.full_name% App\Dataflow\MyDataflow '{"option1": "value1", "option2": "value2"}'</info>
-EOF
-            )
             ->addArgument('fqcn', InputArgument::REQUIRED, 'FQCN or alias of the dataflow type')
             ->addArgument('options', InputArgument::OPTIONAL, 'Options for the dataflow type as a json string', '[]')
             ->addOption('connection', null, InputOption::VALUE_REQUIRED, 'Define the DBAL connection to use');
@@ -54,7 +51,7 @@ protected function execute(InputInterface $input, OutputInterface $output): int
             $this->connectionFactory->setConnectionName($input->getOption('connection'));
         }
         $fqcnOrAlias = $input->getArgument('fqcn');
-        $options = json_decode($input->getArgument('options'), true, 512, \JSON_THROW_ON_ERROR);
+        $options = json_decode((string) $input->getArgument('options'), true, 512, \JSON_THROW_ON_ERROR);
         $io = new SymfonyStyle($input, $output);
 
         $dataflowType = $this->registry->getDataflowType($fqcnOrAlias);
diff --git a/src/Command/JobCleanupCommand.php b/src/Command/JobCleanupCommand.php
@@ -10,17 +10,18 @@
 use Symfony\Component\Console\Input\InputInterface;
 use Symfony\Component\Console\Output\OutputInterface;
 
-#[AsCommand(name: 'code-rhapsodie:job:cleanup', description: 'Cleanup job history.')]
+#[AsCommand(name: 'code-rhapsodie:dataflow:job:cleanup', description: 'Cleanup job history.', help: <<<'TXT'
+Job retention can be configured with the "job_history.retention" configuration.
+TXT)]
 class JobCleanupCommand extends Command
 {
-    public function __construct(private JobRepository $jobRepository, private int $retention)
+    public function __construct(private readonly JobRepository $jobRepository, private readonly int $retention)
     {
         parent::__construct();
     }
 
     protected function configure()
     {
-        $this->setHelp('Job retention can be configured with the "job_history.retention" configuration.');
     }
 
     protected function execute(InputInterface $input, OutputInterface $output): int
diff --git a/src/Command/JobShowCommand.php b/src/Command/JobShowCommand.php
@@ -17,7 +17,9 @@
 /**
  * @codeCoverageIgnore
  */
-#[AsCommand('code-rhapsodie:dataflow:job:show', 'Display job details for schedule or specific job')]
+#[AsCommand('code-rhapsodie:dataflow:job:show', 'Display job details for schedule or specific job', help: <<<'TXT'
+The <info>%command.name%</info> display job details for schedule or specific job.
+TXT)]
 class JobShowCommand extends Command
 {
     private const STATUS_MAPPING = [
@@ -26,15 +28,14 @@ class JobShowCommand extends Command
         Job::STATUS_COMPLETED => 'Completed',
     ];
 
-    public function __construct(private JobGateway $jobGateway, private ConnectionFactory $connectionFactory)
+    public function __construct(private readonly JobGateway $jobGateway, private readonly ConnectionFactory $connectionFactory)
     {
         parent::__construct();
     }
 
     protected function configure(): void
     {
         $this
-            ->setHelp('The <info>%command.name%</info> display job details for schedule or specific job.')
             ->addOption('job-id', null, InputOption::VALUE_REQUIRED, 'Id of the job to get details')
             ->addOption('schedule-id', null, InputOption::VALUE_REQUIRED, 'Id of schedule for last execution details')
             ->addOption('details', null, InputOption::VALUE_NONE, 'Display full details')
diff --git a/src/Command/RunPendingDataflowsCommand.php b/src/Command/RunPendingDataflowsCommand.php
@@ -19,7 +19,9 @@
  *
  * @codeCoverageIgnore
  */
-#[AsCommand('code-rhapsodie:dataflow:run-pending', 'Runs dataflows based on the scheduled defined in the UI.')]
+#[AsCommand('code-rhapsodie:dataflow:run-pending', 'Runs dataflows based on the scheduled defined in the UI.', help: <<<'TXT'
+The <info>%command.name%</info> command runs dataflows according to the schedule defined in the UI by the user.
+TXT)]
 class RunPendingDataflowsCommand extends Command
 {
     use LockableTrait;
@@ -32,11 +34,6 @@ public function __construct(private ScheduledDataflowManagerInterface $manager,
     protected function configure(): void
     {
         $this
-            ->setHelp(
-                <<<'EOF'
-The <info>%command.name%</info> command runs dataflows according to the schedule defined in the UI by the user.
-EOF
-            )
             ->addOption('connection', null, InputOption::VALUE_REQUIRED, 'Define the DBAL connection to use');
     }
 
diff --git a/src/Command/ScheduleListCommand.php b/src/Command/ScheduleListCommand.php
@@ -16,18 +16,19 @@
 /**
  * @codeCoverageIgnore
  */
-#[AsCommand('code-rhapsodie:dataflow:schedule:list', 'List scheduled dataflows')]
+#[AsCommand('code-rhapsodie:dataflow:schedule:list', 'List scheduled dataflows', help: <<<'TXT'
+The <info>%command.name%</info> lists all scheduled dataflows.
+TXT)]
 class ScheduleListCommand extends Command
 {
-    public function __construct(private ScheduledDataflowRepository $scheduledDataflowRepository, private ConnectionFactory $connectionFactory)
+    public function __construct(private readonly ScheduledDataflowRepository $scheduledDataflowRepository, private readonly ConnectionFactory $connectionFactory)
     {
         parent::__construct();
     }
 
     protected function configure(): void
     {
         $this
-            ->setHelp('The <info>%command.name%</info> lists all scheduled dataflows.')
             ->addOption('connection', null, InputOption::VALUE_REQUIRED, 'Define the DBAL connection to use');
     }
 
diff --git a/src/Command/SchemaCommand.php b/src/Command/SchemaCommand.php
@@ -17,13 +17,14 @@
  *
  * @deprecated This command is deprecated and will be removed in 6.0, use this command "code-rhapsodie:dataflow:database-schema" instead.
  */
-#[AsCommand('code-rhapsodie:dataflow:dump-schema', 'Generates schema create / update SQL queries')]
+#[AsCommand('code-rhapsodie:dataflow:dump-schema', 'Generates schema create / update SQL queries', help: <<<'TXT'
+The <info>%command.name%</info> help you to generate SQL Query to create or update your database schema for this bundle
+TXT)]
 class SchemaCommand extends Command
 {
     protected function configure(): void
     {
         $this
-            ->setHelp('The <info>%command.name%</info> help you to generate SQL Query to create or update your database schema for this bundle')
             ->addOption('update', null, InputOption::VALUE_NONE, 'Dump only the update SQL queries.')
             ->addOption('connection', null, InputOption::VALUE_REQUIRED, 'Define the DBAL connection to use')
         ;
diff --git a/src/Command/SetCrashedCommand.php b/src/Command/SetCrashedCommand.php
@@ -10,17 +10,18 @@
 use Symfony\Component\Console\Input\InputInterface;
 use Symfony\Component\Console\Output\OutputInterface;
 
-#[AsCommand(name: 'code-rhapsodie:job:set-crashed', description: 'Set long running jobs as crashed.')]
+#[AsCommand(name: 'code-rhapsodie:dataflow:job:set-crashed', description: 'Set long running jobs as crashed.', help: <<<'TXT'
+How long jobs have to run before they are set as crashed can be configured with the "job_history.crashed_delay" configuration.
+TXT)]
 class SetCrashedCommand extends Command
 {
-    public function __construct(private JobRepository $jobRepository, private int $crashedDelay)
+    public function __construct(private readonly JobRepository $jobRepository, private readonly int $crashedDelay)
     {
         parent::__construct();
     }
 
     protected function configure()
     {
-        $this->setHelp('How long jobs have to run before they are set as crashed can be configured with the "job_history.crashed_delay" configuration.');
     }
 
     protected function execute(InputInterface $input, OutputInterface $output): int
diff --git a/src/DataflowType/Dataflow/Dataflow.php b/src/DataflowType/Dataflow/Dataflow.php
@@ -67,7 +67,7 @@ public function setCustomExceptionIndex(callable $callable): self
      */
     public function setAfterItemProcessors(array $processors): self
     {
-        $this->afterItemProcessors = array_map(static fn (callable $callable) => \Closure::fromCallable($callable), $processors);
+        $this->afterItemProcessors = array_map(\Closure::fromCallable(...), $processors);
 
         return $this;
     }
diff --git a/src/DataflowType/Result.php b/src/DataflowType/Result.php
@@ -9,15 +9,15 @@
  */
 class Result
 {
-    private \DateInterval $elapsed;
+    private readonly \DateInterval $elapsed;
 
     private int $errorCount = 0;
 
     private int $successCount = 0;
 
-    private array $exceptions;
+    private readonly array $exceptions;
 
-    public function __construct(private string $name, private \DateTimeInterface $startTime, private \DateTimeInterface $endTime, private int $totalProcessedCount, array $exceptions)
+    public function __construct(private readonly string $name, private readonly \DateTimeInterface $startTime, private readonly \DateTimeInterface $endTime, private readonly int $totalProcessedCount, array $exceptions)
     {
         $this->elapsed = $startTime->diff($endTime);
         $this->errorCount = \count($exceptions);
diff --git a/src/DataflowType/Writer/CollectionWriter.php b/src/DataflowType/Writer/CollectionWriter.php
@@ -14,7 +14,7 @@ class CollectionWriter implements DelegateWriterInterface
     /**
      * CollectionWriter constructor.
      */
-    public function __construct(private WriterInterface $writer)
+    public function __construct(private readonly WriterInterface $writer)
     {
     }
 
diff --git a/src/DataflowType/Writer/PortWriterAdapter.php b/src/DataflowType/Writer/PortWriterAdapter.php
@@ -6,7 +6,7 @@
 
 class PortWriterAdapter implements WriterInterface
 {
-    public function __construct(private \Port\Writer $writer)
+    public function __construct(private readonly \Port\Writer $writer)
     {
     }
 
diff --git a/src/Event/ProcessingEvent.php b/src/Event/ProcessingEvent.php
@@ -16,7 +16,7 @@ class ProcessingEvent extends CrEvent
     /**
      * ProcessingEvent constructor.
      */
-    public function __construct(private Job $job)
+    public function __construct(private readonly Job $job)
     {
     }
 
diff --git a/src/ExceptionsHandler/FilesystemExceptionHandler.php b/src/ExceptionsHandler/FilesystemExceptionHandler.php
@@ -9,7 +9,7 @@
 
 class FilesystemExceptionHandler implements ExceptionHandlerInterface
 {
-    public function __construct(private Filesystem $filesystem)
+    public function __construct(private readonly Filesystem $filesystem)
     {
     }
 
diff --git a/src/Factory/ConnectionFactory.php b/src/Factory/ConnectionFactory.php
@@ -13,7 +13,7 @@
  */
 class ConnectionFactory
 {
-    public function __construct(private Container $container, private string $connectionName)
+    public function __construct(private readonly Container $container, private string $connectionName)
     {
     }
 
diff --git a/src/Gateway/JobGateway.php b/src/Gateway/JobGateway.php
@@ -11,7 +11,7 @@
 
 class JobGateway
 {
-    public function __construct(private JobRepository $repository, private ExceptionHandlerInterface $exceptionHandler)
+    public function __construct(private readonly JobRepository $repository, private readonly ExceptionHandlerInterface $exceptionHandler)
     {
     }
 
diff --git a/src/Manager/ScheduledDataflowManager.php b/src/Manager/ScheduledDataflowManager.php
@@ -15,7 +15,7 @@
  */
 class ScheduledDataflowManager implements ScheduledDataflowManagerInterface
 {
-    public function __construct(private Connection $connection, private ScheduledDataflowRepository $scheduledDataflowRepository, private JobRepository $jobRepository)
+    public function __construct(private readonly Connection $connection, private readonly ScheduledDataflowRepository $scheduledDataflowRepository, private readonly JobRepository $jobRepository)
     {
     }
 
diff --git a/src/MessengerMode/JobMessage.php b/src/MessengerMode/JobMessage.php
@@ -6,7 +6,7 @@
 
 class JobMessage
 {
-    public function __construct(private int $jobId)
+    public function __construct(private readonly int $jobId)
     {
     }
 
diff --git a/src/MessengerMode/JobMessageHandler.php b/src/MessengerMode/JobMessageHandler.php
diff --git a/src/Repository/JobRepository.php b/src/Repository/JobRepository.php
diff --git a/src/Runner/MessengerDataflowRunner.php b/src/Runner/MessengerDataflowRunner.php
diff --git a/src/Runner/PendingDataflowRunner.php b/src/Runner/PendingDataflowRunner.php

Original file line number	Diff line number	Diff line change
`@@ -18,7 +18,7 @@ public function testProcess()`
`18`	`18`
`19`	`19`	`$dataflowType = new class($label, $options, $values, $testCase) extends AbstractDataflowType`
`20`	`20`	`{`
`21`		`- public function __construct(private string $label, private array $options, private array $values, private TestCase $testCase)`
	`21`	`+ public function __construct(private readonly string $label, private readonly array $options, private readonly array $values, private readonly TestCase $testCase)`
`22`	`22`	`{`
`23`	`23`	`}`
`24`	`24`
Original file line number	Diff line number	Diff line change
`@@ -41,7 +41,7 @@`
`41`	`41`	`}`
`42`	`42`	`},`
`43`	`43`	`"require": {`
`44`		`- "php": "^8.0",`
	`44`	`+ "php": "^8.2",`
`45`	`45`	`"ext-json": "*",`
`46`	`46`	`"doctrine/dbal": "^3.0\|\|^4.0",`
`47`	`47`	`"doctrine/doctrine-bundle": "^2.0",`
Original file line number	Diff line number	Diff line change
`@@ -19,18 +19,19 @@`
`19`	`19`	`/**`
`20`	`20`	`* @codeCoverageIgnore`
`21`	`21`	`*/`
`22`		`-#[AsCommand('code-rhapsodie:dataflow:schedule:add', 'Create a scheduled dataflow')]`
	`22`	`+#[AsCommand('code-rhapsodie:dataflow:schedule:add', 'Create a scheduled dataflow', help: <<<'TXT'`
	`23`	`+The <info>%command.name%</info> allows you to create a new scheduled dataflow.`
	`24`	`+TXT)]`
`23`	`25`	`class AddScheduledDataflowCommand extends Command`
`24`	`26`	`{`
`25`		`- public function __construct(private DataflowTypeRegistryInterface $registry, private ScheduledDataflowRepository $scheduledDataflowRepository, private ValidatorInterface $validator, private ConnectionFactory $connectionFactory)`
	`27`	`+ public function __construct(private readonly DataflowTypeRegistryInterface $registry, private readonly ScheduledDataflowRepository $scheduledDataflowRepository, private readonly ValidatorInterface $validator, private readonly ConnectionFactory $connectionFactory)`
`26`	`28`	`{`
`27`	`29`	`parent::__construct();`
`28`	`30`	`}`
`29`	`31`
`30`	`32`	`protected function configure(): void`
`31`	`33`	`{`
`32`	`34`	`$this`
`33`		`- ->setHelp('The <info>%command.name%</info> allows you to create a new scheduled dataflow.')`
`34`	`35`	`->addOption('label', null, InputOption::VALUE_REQUIRED, 'Label of the scheduled dataflow')`
`35`	`36`	`->addOption('type', null, InputOption::VALUE_REQUIRED, 'Type of the scheduled dataflow (FQCN)')`
`36`	`37`	`->addOption(`
Original file line number	Diff line number	Diff line change
`@@ -18,18 +18,19 @@`
`18`	`18`	`/**`
`19`	`19`	`* @codeCoverageIgnore`
`20`	`20`	`*/`
`21`		`-#[AsCommand('code-rhapsodie:dataflow:schedule:change-status', 'Change schedule status')]`
	`21`	`+#[AsCommand('code-rhapsodie:dataflow:schedule:change-status', 'Change schedule status', help: <<<'TXT'`
	`22`	`+The <info>%command.name%</info> command able you to change schedule status.`
	`23`	`+TXT)]`
`22`	`24`	`class ChangeScheduleStatusCommand extends Command`
`23`	`25`	`{`
`24`		`- public function __construct(private ScheduledDataflowRepository $scheduledDataflowRepository, private ConnectionFactory $connectionFactory)`
	`26`	`+ public function __construct(private readonly ScheduledDataflowRepository $scheduledDataflowRepository, private readonly ConnectionFactory $connectionFactory)`
`25`	`27`	`{`
`26`	`28`	`parent::__construct();`
`27`	`29`	`}`
`28`	`30`
`29`	`31`	`protected function configure(): void`
`30`	`32`	`{`
`31`	`33`	`$this`
`32`		`- ->setHelp('The <info>%command.name%</info> command able you to change schedule status.')`
`33`	`34`	`->addArgument('schedule-id', InputArgument::REQUIRED, 'Id of the schedule')`
`34`	`35`	`->addOption('enable', null, InputOption::VALUE_NONE, 'Enable the schedule')`
`35`	`36`	`->addOption('disable', null, InputOption::VALUE_NONE, 'Disable the schedule')`
Original file line number	Diff line number	Diff line change
`@@ -10,17 +10,18 @@`
`10`	`10`	`use Symfony\Component\Console\Input\InputInterface;`
`11`	`11`	`use Symfony\Component\Console\Output\OutputInterface;`
`12`	`12`
`13`		`-#[AsCommand(name: 'code-rhapsodie:job:cleanup', description: 'Cleanup job history.')]`
	`13`	`+#[AsCommand(name: 'code-rhapsodie:dataflow:job:cleanup', description: 'Cleanup job history.', help: <<<'TXT'`
	`14`	`+Job retention can be configured with the "job_history.retention" configuration.`
	`15`	`+TXT)]`
`14`	`16`	`class JobCleanupCommand extends Command`
`15`	`17`	`{`
`16`		`- public function __construct(private JobRepository $jobRepository, private int $retention)`
	`18`	`+ public function __construct(private readonly JobRepository $jobRepository, private readonly int $retention)`
`17`	`19`	`{`
`18`	`20`	`parent::__construct();`
`19`	`21`	`}`
`20`	`22`
`21`	`23`	`protected function configure()`
`22`	`24`	`{`
`23`		`- $this->setHelp('Job retention can be configured with the "job_history.retention" configuration.');`
`24`	`25`	`}`
`25`	`26`
`26`	`27`	`protected function execute(InputInterface $input, OutputInterface $output): int`