added azure related code

[it/otf.git] / otf-camunda / src / main / java / org / oran / otf / camunda / workflow / WorkflowProcessor.java

diff --git a/otf-camunda/src/main/java/org/oran/otf/camunda/workflow/WorkflowProcessor.java b/otf-camunda/src/main/java/org/oran/otf/camunda/workflow/WorkflowProcessor.java
index 10a1dfd..3230fb7 100644 (file)
--- a/otf-camunda/src/main/java/org/oran/otf/camunda/workflow/WorkflowProcessor.java
+++ b/otf-camunda/src/main/java/org/oran/otf/camunda/workflow/WorkflowProcessor.java
@@ -345,6 +345,8 @@ public class WorkflowProcessor extends ProcessEngineAwareService {
             // available.\r
             testExecution.setProcessInstanceId(processInstance.getProcessInstanceId());\r
             Query query = new Query();\r
+            //TODO: Update for Azure\r
+            query.addCriteria((Criteria.where("groupId").is(testExecution.getGroupId())));\r
             query.addCriteria(Criteria.where("_id").is(testExecution.get_id()));\r
             // Also add businessKey as a criteria because the object won't be found if the business key\r
             // was somehow modified in the workflow.\r
@@ -407,6 +409,8 @@ public class WorkflowProcessor extends ProcessEngineAwareService {
             // available.\r
             testExecution.setProcessInstanceId(processInstance.getProcessInstanceId());\r
             Query query = new Query();\r
+            //TODO: Update for Azure\r
+            query.addCriteria((Criteria.where("groupId").is(testExecution.getGroupId())));\r
             query.addCriteria(Criteria.where("_id").is(testExecution.get_id()));\r
             // Also add businessKey as a criteria because the object won't be found if the business key\r
             // was somehow modified in the workflow.\r