From 410e7a2867fe434b5cc77e05dd65acb3dd554021 Mon Sep 17 00:00:00 2001 From: johbuch Date: Wed, 21 Jan 2026 14:41:48 +0100 Subject: [PATCH 1/2] fix: sql update query --- Repository/EtlExecutionRepository.php | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/Repository/EtlExecutionRepository.php b/Repository/EtlExecutionRepository.php index 34d9e71..2651a64 100644 --- a/Repository/EtlExecutionRepository.php +++ b/Repository/EtlExecutionRepository.php @@ -32,13 +32,13 @@ public function updateStepStats(EtlExecution $execution, string $stepStats): voi /** @var \Doctrine\DBAL\Connection $connection */ $connection = $this->registry->getConnection(); - $query = $connection->createQueryBuilder() - ->update('EtlExecution', 'e') + $query = $this->createQueryBuilder('e') + ->update() ->set('e.stepStats', ':stepStats') ->where('e.id = :executionId') ->setParameter('stepStats', $stepStats) ->setParameter('executionId', $execution->getId()); - $query->executeQuery(); + $query->execute(); if ($connection->getTransactionNestingLevel() > 0) { $connection->commit(); From 044e7fc4a814a8eeb4f56b3b5c98a6dd7ec5035d Mon Sep 17 00:00:00 2001 From: johbuch Date: Wed, 21 Jan 2026 14:56:56 +0100 Subject: [PATCH 2/2] fix: nullable in function parameter --- Services/ChainProcessorsManager.php | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/Services/ChainProcessorsManager.php b/Services/ChainProcessorsManager.php index a352ec9..63a42d2 100644 --- a/Services/ChainProcessorsManager.php +++ b/Services/ChainProcessorsManager.php @@ -106,7 +106,7 @@ public function execute(string $chainName, iterable $iterator, array $params, ? * Execute a chain from it's entity. * */ - public function executeFromEtlEntity(EtlExecution $execution, iterable $iterator = null, ?callable $observerCallback = null): void + public function executeFromEtlEntity(EtlExecution $execution, ?iterable $iterator = null, ?callable $observerCallback = null): void { $chainName = $execution->getName(); $logger = $this->loggerFactory->get($execution);