test/timeout_test.rb in ruote-0.9.18 vs test/timeout_test.rb in ruote-0.9.19

@@ -15,91 +15,91 @@
 require 'rutest_utils'
 
 
 class TimeoutTest < Test::Unit::TestCase
 
-    #def setup
-    #    @engine = $WORKFLOW_ENGINE_CLASS.new()
-    #end
+  #def setup
+  #  @engine = $WORKFLOW_ENGINE_CLASS.new()
+  #end
 
-    #def teardown
-    #end
+  #def teardown
+  #end
 
-    class TimeoutDefinition0 < OpenWFE::ProcessDefinition
-        sequence do
-            participant :ref => "albert", :timeout => "500"
-            _print "timedout? ${f:__timed_out__}"
-            _print "over ${f:done}"
-        end
+  class TimeoutDefinition0 < OpenWFE::ProcessDefinition
+    sequence do
+      participant :ref => "albert", :timeout => "500"
+      _print "timedout? ${f:__timed_out__}"
+      _print "over ${f:done}"
     end
+  end
 
-    def test_timeout_0
+  def test_timeout_0
 
-        albert = OpenWFE::HashParticipant.new
+    albert = OpenWFE::HashParticipant.new
 
-        engine = OpenWFE::Engine.new :definition_in_launchitem_allowed => true
+    engine = OpenWFE::Engine.new :definition_in_launchitem_allowed => true
 
-        engine.application_context["__tracer"] = Tracer.new
+    engine.application_context["__tracer"] = Tracer.new
 
-        engine.register_participant :albert, albert
+    engine.register_participant :albert, albert
 
-        li = OpenWFE::LaunchItem.new TimeoutDefinition0
+    li = OpenWFE::LaunchItem.new TimeoutDefinition0
 
-        engine.launch li
+    engine.launch li
 
-        sleep 2
+    sleep 2
 
-        s = engine.application_context["__tracer"].to_s
+    s = engine.application_context["__tracer"].to_s
 
-        engine.stop
+    engine.stop
 
-        #puts "trace is >#{s}<"
-        #puts "albert.size is #{albert.size}"
+    #puts "trace is >#{s}<"
+    #puts "albert.size is #{albert.size}"
 
-        assert_equal 0, albert.size, "wi was not removed from workitem store"
-        assert_equal "timedout? true\nover", s, "flow did not reach 'over'"
-    end
+    assert_equal 0, albert.size, "wi was not removed from workitem store"
+    assert_equal "timedout? true\nover", s, "flow did not reach 'over'"
+  end
 
-    def test_timeout_1
+  def test_timeout_1
 
-        albert = OpenWFE::HashParticipant.new
+    albert = OpenWFE::HashParticipant.new
 
-        engine = OpenWFE::Engine.new :definition_in_launchitem_allowed => true
+    engine = OpenWFE::Engine.new :definition_in_launchitem_allowed => true
 
-        engine.application_context["__tracer"] = Tracer.new
+    engine.application_context["__tracer"] = Tracer.new
 
-        engine.register_participant(:albert, albert)
+    engine.register_participant(:albert, albert)
 
-        pjc = engine.get_scheduler.pending_job_count
-        assert \
-            pjc == 0,
-            "0 pending_jobs_count is at #{pjc}, it should be at 0"
+    pjc = engine.get_scheduler.pending_job_count
+    assert \
+      pjc == 0,
+      "0 pending_jobs_count is at #{pjc}, it should be at 0"
 
-        li = OpenWFE::LaunchItem.new TimeoutDefinition0
+    li = OpenWFE::LaunchItem.new TimeoutDefinition0
 
-        engine.launch li
+    engine.launch li
 
-        sleep 0.300
+    sleep 0.300
 
-        wi = albert.list_workitems(nil)[0]
-        wi.done = "ok"
-        albert.proceed(wi)
+    wi = albert.list_workitems(nil)[0]
+    wi.done = "ok"
+    albert.proceed(wi)
 
-        sleep 0.300
+    sleep 0.300
 
-        s = engine.application_context["__tracer"].to_s
+    s = engine.application_context["__tracer"].to_s
 
-        #puts "trace is >#{s}<"
-        #puts "albert.size is #{albert.size}"
+    #puts "trace is >#{s}<"
+    #puts "albert.size is #{albert.size}"
 
-        # in this test, the participant doesn't time out
+    # in this test, the participant doesn't time out
 
-        assert_equal 0, albert.size, "wi was not removed from workitem store"
-        assert_equal "timedout? \nover ok", s, "flow did not reach 'over ok'"
+    assert_equal 0, albert.size, "wi was not removed from workitem store"
+    assert_equal "timedout? \nover ok", s, "flow did not reach 'over ok'"
 
-        pjc = engine.get_scheduler.pending_job_count
+    pjc = engine.get_scheduler.pending_job_count
 
-        assert_equal 0, pjc, "pending_jobs_count is at #{pjc}, should be at 0"
-    end
+    assert_equal 0, pjc, "pending_jobs_count is at #{pjc}, should be at 0"
+  end
 
 end