This is an automated email from the ASF dual-hosted git repository. jstastnycz pushed a commit to branch sync-20250907 in repository https://gitbox.apache.org/repos/asf/incubator-kie-kogito-apps.git
commit 2a30d2b2550a0d455603178dfd0994cd69f0f7d3 Author: Enrique <[email protected]> AuthorDate: Thu Aug 28 19:17:55 2025 +0200 [NO_ISSUE] job process instance executor create instance (#2263) * [NO_ISSUE] job process instance executor create instance * correction start instead of signal * formatting --- .../kie/kogito/app/jobs/integregations/ProcessJobExecutor.java | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/jobs/jobs-common-embedded/src/main/java/org/kie/kogito/app/jobs/integregations/ProcessJobExecutor.java b/jobs/jobs-common-embedded/src/main/java/org/kie/kogito/app/jobs/integregations/ProcessJobExecutor.java index 6fa71148e..be86f848e 100644 --- a/jobs/jobs-common-embedded/src/main/java/org/kie/kogito/app/jobs/integregations/ProcessJobExecutor.java +++ b/jobs/jobs-common-embedded/src/main/java/org/kie/kogito/app/jobs/integregations/ProcessJobExecutor.java @@ -23,10 +23,9 @@ import org.kie.kogito.app.jobs.impl.JobDetailsHelper; import org.kie.kogito.jobs.descriptors.ProcessJobDescription; import org.kie.kogito.jobs.service.model.JobDetails; import org.kie.kogito.process.Process; +import org.kie.kogito.process.ProcessInstance; import org.kie.kogito.process.Processes; -import org.kie.kogito.process.SignalFactory; import org.kie.kogito.services.uow.UnitOfWorkExecutor; -import org.kie.kogito.timer.TimerInstance; import org.kie.kogito.uow.UnitOfWorkManager; public class ProcessJobExecutor implements JobExecutor { @@ -51,11 +50,12 @@ public class ProcessJobExecutor implements JobExecutor { ProcessJobDescription processJobDescription = (ProcessJobDescription) JobDetailsHelper.extractJobDescription(jobDetails); UnitOfWorkExecutor.executeInUnitOfWork(uom, () -> { - Process<?> processDefinition = processes.processById(processJobDescription.processId()); + Process processDefinition = processes.processById(processJobDescription.processId()); if (processDefinition == null) { return null; } - processDefinition.send(SignalFactory.of(SIGNAL, TimerInstance.with(jobDetails.getId(), jobDetails.getId(), -1))); + ProcessInstance pi = processDefinition.createInstance(processDefinition.createModel()); + pi.start("timer", null); return null; }); } --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
