test/ft_27_getflowpos.rb in openwferu-0.9.9 vs test/ft_27_getflowpos.rb in openwferu-0.9.10

@@ -41,33 +41,48 @@
         #sp = @engine.register_participant("store_p", OpenWFE::YamlParticipant)
         sp = @engine.register_participant("store_p", OpenWFE::HashParticipant)
 
         fei = @engine.launch(TestDefinition0)
 
+        sleep 0.500
+
         l = @engine.get_expression_pool.get_flow_position(fei.wfid)
 
         #print_exp_list(l)
 
-        assert \
-            l.size == 3, 
-            "get_flow_position() returned #{l.size} elements"
+        assert_equal \
+            l.size, 3, "get_flow_position() returned #{l.size} elements"
 
         wi = sp.first_workitem
 
         sp.forward(wi)
 
+        @engine.wait_for fei
+
         assert_equal sp.size, 0
     end
 
 
+    #
+    # TEST 0b
+
+    class Gfp27b < ProcessDefinition
+        sequence do
+            store_p
+        end
+    end
+
     #def xxxx_gfp_0b
     def test_gfp_0b
 
         sp = @engine.register_participant("store_p", OpenWFE::YamlParticipant)
 
-        fei = @engine.launch(TestDefinition0)
+        #fei = @engine.launch TestDefinition0
+        fei = @engine.launch Gfp27b
 
+        sleep 0.500
+
         l = @engine.get_flow_position(fei.wfid)
             #
             # shortcut version
 
         #print_exp_list l
@@ -89,9 +104,11 @@
         wi = sp.first_workitem
 
         assert wi
 
         sp.forward(wi)
+
+        @engine.wait_for fei
 
         assert_equal sp.size, 0
     end
 
 end