This is an automated email from the ASF dual-hosted git repository.
egonzalez pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/incubator-kie-kogito-apps.git
The following commit(s) were added to refs/heads/main by this push:
new 8266e9d1c [NO_ISSUE] job process instance executor create instance
(#2263)
8266e9d1c is described below
commit 8266e9d1cc6977ad541dc1de2eeabaf1cc3db71e
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
---
.../org/kie/kogito/app/jobs/integrations/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/integrations/ProcessJobExecutor.java
b/jobs/jobs-common-embedded/src/main/java/org/kie/kogito/app/jobs/integrations/ProcessJobExecutor.java
index 773d458eb..1a31f98ee 100644
---
a/jobs/jobs-common-embedded/src/main/java/org/kie/kogito/app/jobs/integrations/ProcessJobExecutor.java
+++
b/jobs/jobs-common-embedded/src/main/java/org/kie/kogito/app/jobs/integrations/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]
