feat(engine): Populating process instance id in jobs

related to camunda#4205
punitdarira · May 13, 2024 · 4e97dc1 · 4e97dc1
1 parent 96c1bf3
commit 4e97dc1
Show file tree

Hide file tree

Showing 3 changed files with 7 additions and 8 deletions.
diff --git a/engine/src/main/java/org/camunda/bpm/engine/impl/batch/AbstractBatchJobHandler.java b/engine/src/main/java/org/camunda/bpm/engine/impl/batch/AbstractBatchJobHandler.java
@@ -169,6 +169,11 @@ protected void createJobEntities(BatchEntity batch, T configuration, String depl
       ByteArrayEntity configurationEntity = saveConfiguration(byteArrayManager, jobConfiguration);
 
       JobEntity job = createBatchJob(batch, configurationEntity);
+
+      if (jobConfiguration.getIds() != null && jobConfiguration.getIds().size() == 1) {
+        job.setProcessInstanceId(jobConfiguration.getIds().get(0));
+      }
+
       job.setDeploymentId(deploymentId);
       postProcessJob(configuration, job, jobConfiguration);
       jobManager.insertAndHintJobExecutor(job);

diff --git a/...ain/java/org/camunda/bpm/engine/impl/batch/message/MessageCorrelationBatchJobHandler.java b/...ain/java/org/camunda/bpm/engine/impl/batch/message/MessageCorrelationBatchJobHandler.java
@@ -66,10 +66,7 @@ protected MessageCorrelationBatchConfiguration createJobConfiguration(MessageCor
 
   @Override
   protected void postProcessJob(MessageCorrelationBatchConfiguration configuration, JobEntity job, MessageCorrelationBatchConfiguration jobConfiguration) {
-    // if there is only one process instance to adjust, set its ID to the job so exclusive scheduling is possible
-    if (jobConfiguration.getIds() != null && jobConfiguration.getIds().size() == 1) {
-      job.setProcessInstanceId(jobConfiguration.getIds().get(0));
-    }
+
   }
 
   @Override

diff --git a/...e/src/main/java/org/camunda/bpm/engine/impl/batch/variables/BatchSetVariablesHandler.java b/...e/src/main/java/org/camunda/bpm/engine/impl/batch/variables/BatchSetVariablesHandler.java
@@ -78,10 +78,7 @@ public String getType() {
 
   @Override
   protected void postProcessJob(BatchConfiguration configuration, JobEntity job, BatchConfiguration jobConfiguration) {
-    // if there is only one process instance to adjust, set its ID to the job so exclusive scheduling is possible
-    if (jobConfiguration.getIds() != null && jobConfiguration.getIds().size() == 1) {
-      job.setProcessInstanceId(jobConfiguration.getIds().get(0));
-    }
+
   }
 
   protected ByteArrayEntity findByteArrayById(String byteArrayId, CommandContext commandContext) {