Skip to content

Commit

Permalink
2023.09.27 Merge branch 'bugfix/fixCompensation' into dev
Browse files Browse the repository at this point in the history
  • Loading branch information
monkenWu committed Sep 27, 2023
2 parents 2a32ec3 + da0cc9e commit e29a430
Showing 1 changed file with 2 additions and 1 deletion.
3 changes: 2 additions & 1 deletion src/Orchestration/Orchestrator.php
Original file line number Diff line number Diff line change
Expand Up @@ -279,7 +279,8 @@ public function startAllStep(CacheHandlerInterface $cacheInstance = null)

if ($this->isSuccess() === false) {
if (is_null($this->sagaInstance) === false) {
if (!$this->startOrchCompensation() || is_null($this->startOrchCompensation())) {
$transResult = $this->startOrchCompensation();
if (!$transResult || is_null($transResult)) {
if($this->defineFailResult() instanceof OrchestratorException) {
throw OrchestratorException::forStepExecuteFail(static::class, "compensate");
}
Expand Down

0 comments on commit e29a430

Please sign in to comment.