diff --git a/src/Orchestration/Orchestrator.php b/src/Orchestration/Orchestrator.php index 0315caf..d0f449b 100644 --- a/src/Orchestration/Orchestrator.php +++ b/src/Orchestration/Orchestrator.php @@ -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"); }