Skip to content

Commit b154452

Browse files
committed
Fix etl execution not reloaded from database at end of process. This is necessary if the doctrine memory is flushed in the etl process.
1 parent d046cc9 commit b154452

File tree

2 files changed

+4
-1
lines changed

2 files changed

+4
-1
lines changed

CHANGELOG.md

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1,3 +1,6 @@
1+
# 1.0.2
2+
- :wrench: Fix incase of failire etl execution being duplicated and loosing logs and files.
3+
14
# 1.0.1
25
- :wrench: Fix etl execution not reloaded from database at end of process. This is necessary if the doctrine memory is flushed in the etl process.
36

Services/ChainProcessorsManager.php

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -125,12 +125,12 @@ public function executeFromEtlEntity(EtlExecution $execution, iterable $iterator
125125
$execution = $this->etlExecutionRepository->find($execution->getId());
126126
$execution->setStatus(EtlExecution::STATUS_SUCCESS);
127127
} catch (\Throwable $exception) {
128+
$execution = $this->etlExecutionRepository->find($execution->getId());
128129
$execution->setFailTime(new \DateTime());
129130
$execution->setStatus(EtlExecution::STATUS_FAILURE);
130131
$execution->setErrorMessage($this->getFullExeptionTrace($exception));
131132
throw $exception;
132133
} finally {
133-
$execution = $this->etlExecutionRepository->find($execution->getId());
134134
$execution->setEndTime(new \DateTime());
135135
$execution->setRunTime(time() - $execution->getStartTime()->getTimestamp());
136136
$execution->setStepStats('[]'); // To be developped

0 commit comments

Comments
 (0)