added azure related code

[it/otf.git] / otf-camunda / src / main / java / org / oran / otf / camunda / listener / StartEventListener.java

diff --git a/otf-camunda/src/main/java/org/oran/otf/camunda/listener/StartEventListener.java b/otf-camunda/src/main/java/org/oran/otf/camunda/listener/StartEventListener.java
index 9fa6d14..b8a7424 100644 (file)
--- a/otf-camunda/src/main/java/org/oran/otf/camunda/listener/StartEventListener.java
+++ b/otf-camunda/src/main/java/org/oran/otf/camunda/listener/StartEventListener.java
@@ -20,6 +20,7 @@ import org.oran.otf.camunda.exception.TestExecutionException;
 import org.oran.otf.camunda.model.ExecutionConstants;\r
 import org.oran.otf.camunda.workflow.utility.WorkflowUtility;\r
 import org.oran.otf.common.model.TestExecution;\r
+import org.oran.otf.common.repository.TestExecutionRepository;\r
 import org.oran.otf.common.utility.Utility;\r
 import com.google.gson.JsonObject;\r
 import com.mongodb.client.result.UpdateResult;\r
@@ -83,8 +84,9 @@ public class StartEventListener extends ReactorExecutionListener {
     testExecution.setTestResult(result);\r
     testExecution.setProcessInstanceId(execution.getProcessInstanceId());\r
 \r
-\r
     Query query = new Query();\r
+    //TODO: Update needs new query for Azure\r
+    query.addCriteria((Criteria.where("groupId").is(testExecution.getGroupId())));\r
     query.addCriteria(Criteria.where("businessKey").is(execution.getProcessBusinessKey()));\r
     Update update = new Update();\r
     update.set("testResult", testExecution.getTestResult());\r