diff options
author | waqas.ikram <waqas.ikram@est.tech> | 2020-09-09 15:07:42 +0100 |
---|---|---|
committer | waqas.ikram <waqas.ikram@est.tech> | 2020-09-09 15:07:45 +0100 |
commit | fa1aa4e2179d9f852d7025d026685bd72385ce4b (patch) | |
tree | 7764e461a993efe5e40d8917cc3f57ab33b4a27d | |
parent | bd86a224c44dcc5192d0b5a142c6be0f779a90a8 (diff) |
Fixing intermediate test failure
Change-Id: I115657fee925cd0c3e582e70d9cd8f498cf4f59a
Issue-ID: SO-2868
Signed-off-by: waqas.ikram <waqas.ikram@est.tech>
-rw-r--r-- | so-etsi-nfvo/so-etsi-nfvo-ns-lcm/so-etsi-nfvo-ns-lcm-bpmn-flows/src/test/java/org/onap/so/etsi/nfvo/ns/lcm/bpmn/flows/BaseTest.java | 12 |
1 files changed, 10 insertions, 2 deletions
diff --git a/so-etsi-nfvo/so-etsi-nfvo-ns-lcm/so-etsi-nfvo-ns-lcm-bpmn-flows/src/test/java/org/onap/so/etsi/nfvo/ns/lcm/bpmn/flows/BaseTest.java b/so-etsi-nfvo/so-etsi-nfvo-ns-lcm/so-etsi-nfvo-ns-lcm-bpmn-flows/src/test/java/org/onap/so/etsi/nfvo/ns/lcm/bpmn/flows/BaseTest.java index fc9f2a2195..86f2879966 100644 --- a/so-etsi-nfvo/so-etsi-nfvo-ns-lcm/so-etsi-nfvo-ns-lcm-bpmn-flows/src/test/java/org/onap/so/etsi/nfvo/ns/lcm/bpmn/flows/BaseTest.java +++ b/so-etsi-nfvo/so-etsi-nfvo-ns-lcm/so-etsi-nfvo-ns-lcm-bpmn-flows/src/test/java/org/onap/so/etsi/nfvo/ns/lcm/bpmn/flows/BaseTest.java @@ -19,6 +19,7 @@ */ package org.onap.so.etsi.nfvo.ns.lcm.bpmn.flows; +import static org.camunda.bpm.engine.history.HistoricProcessInstance.STATE_ACTIVE; import static org.slf4j.LoggerFactory.getLogger; import java.time.LocalDateTime; import java.util.List; @@ -134,9 +135,16 @@ public abstract class BaseTest { public boolean isProcessEndedByProcessInstanceId(final String processInstanceId) { + return !isProcessInstanceActive(processInstanceId) && isProcessInstanceEnded(processInstanceId); + } + + private boolean isProcessInstanceActive(final String processInstanceId) { final HistoricProcessInstance processInstance = getHistoricProcessInstance(processInstanceId); - return processInstance != null - && !HistoricProcessInstance.STATE_ACTIVE.equalsIgnoreCase(processInstance.getState()); + return processInstance != null && STATE_ACTIVE.equalsIgnoreCase(processInstance.getState()); + } + + private boolean isProcessInstanceEnded(final String processInstanceId) { + return runtimeService.createProcessInstanceQuery().processInstanceId(processInstanceId).singleResult() == null; } } |