[DROOLS-6141] executable-model test failure in test-compiler-integrat…

…ion ParallelEvaluationTest (apache#4497) - Implemented insertAsync in exec-model
kiegroup · Jun 28, 2022 · 8c1ca89 · 8c1ca89
1 parent 60d3802
commit 8c1ca89
Show file tree

Hide file tree

Showing 4 changed files with 9 additions and 2 deletions.
diff --git a/drools-model/drools-canonical-model/src/main/java/org/drools/model/Drools.java b/drools-model/drools-canonical-model/src/main/java/org/drools/model/Drools.java
@@ -32,4 +32,6 @@ public interface Drools extends DroolsEntryPoint {
     Channel getChannel(String name);
 
     void logicalInsert(Object object);
+
+    void insertAsync(Object object);
 }
diff --git a/...-model-compiler/src/main/java/org/drools/modelcompiler/builder/generator/Consequence.java b/...-model-compiler/src/main/java/org/drools/modelcompiler/builder/generator/Consequence.java
@@ -100,6 +100,7 @@ private Expression createAsKnowledgeHelperExpression() {
     static {
         implicitDroolsMethods.add("insert");
         implicitDroolsMethods.add("insertLogical");
+        implicitDroolsMethods.add("insertAsync");
         implicitDroolsMethods.add("delete");
         implicitDroolsMethods.add("retract");
         implicitDroolsMethods.add("update");

diff --git a/.../drools-model-compiler/src/main/java/org/drools/modelcompiler/consequence/DroolsImpl.java b/.../drools-model-compiler/src/main/java/org/drools/modelcompiler/consequence/DroolsImpl.java
@@ -65,6 +65,11 @@ public void logicalInsert(Object object) {
         knowledgeHelper.insertLogical( object );
     }
 
+    @Override
+    public void insertAsync(Object object) {
+        ((InternalWorkingMemoryActions)workingMemory).insertAsync(object);
+    }
+
     @Override
     public RuleImpl getRule() {
         return knowledgeHelper.getRule();

diff --git a/...er-integration/src/test/java/org/drools/mvel/integrationtests/ParallelEvaluationTest.java b/...er-integration/src/test/java/org/drools/mvel/integrationtests/ParallelEvaluationTest.java
@@ -74,8 +74,7 @@ public ParallelEvaluationTest(final KieBaseTestConfiguration kieBaseTestConfigur
 
     @Parameterized.Parameters(name = "KieBase type={0}")
     public static Collection<Object[]> getParameters() {
-     // TODO: EM failed with some tests. File JIRAs
-        return TestParametersUtil.getKieBaseCloudConfigurations(false);
+        return TestParametersUtil.getKieBaseCloudConfigurations(true);
     }
 
     @Test(timeout = 40000L)