diff --git a/ProcessMaker/ImportExport/Exporters/ScriptExecutorExporter.php b/ProcessMaker/ImportExport/Exporters/ScriptExecutorExporter.php index 0f3e8a1444..7f19142a6f 100644 --- a/ProcessMaker/ImportExport/Exporters/ScriptExecutorExporter.php +++ b/ProcessMaker/ImportExport/Exporters/ScriptExecutorExporter.php @@ -5,6 +5,7 @@ use Illuminate\Support\Facades\Auth; use ProcessMaker\Events\ScriptExecutorUpdated; use ProcessMaker\Jobs\BuildScriptExecutor; +use ProcessMaker\Jobs\MoveScriptExecutorToMicroservice; use ProcessMaker\Models\ScriptExecutor; use ProcessMaker\Models\User; @@ -28,7 +29,11 @@ public function import() : bool case 'copy': case 'new': // afterCommit is needed because we are in a db transaction - BuildScriptExecutor::dispatch($this->model->id, $userId)->afterCommit(); + if (!config('script-runner-microservice.enabled')) { + BuildScriptExecutor::dispatch($this->model->id, $userId)->afterCommit(); + } else { + MoveScriptExecutorToMicroservice::dispatch($this->model->uuid)->afterCommit(); + } break; case 'update': if (!empty($this->model->getChanges())) { @@ -40,7 +45,11 @@ public function import() : bool $user = User::where('is_administrator', 1)->first(); } // afterCommit is needed because we are in a db transaction - BuildScriptExecutor::dispatch($this->model->id, $user->id)->afterCommit(); + if (!config('script-runner-microservice.enabled')) { + BuildScriptExecutor::dispatch($this->model->id, $userId)->afterCommit(); + } else { + MoveScriptExecutorToMicroservice::dispatch($this->model->uuid)->afterCommit(); + } } break; diff --git a/ProcessMaker/Jobs/MoveScriptExecutorToMicroservice.php b/ProcessMaker/Jobs/MoveScriptExecutorToMicroservice.php new file mode 100644 index 0000000000..584b7b6f01 --- /dev/null +++ b/ProcessMaker/Jobs/MoveScriptExecutorToMicroservice.php @@ -0,0 +1,27 @@ +uuid ); + } +}