test/ft_32d_journal.rb in openwferu-0.9.15 vs test/ft_32d_journal.rb in openwferu-0.9.16
- old
+ new
@@ -40,11 +40,11 @@
#def xxxx_0
def test_0
@engine.application_context[:keep_journals] = true
- @engine.init_service("journal", Journal)
+ @engine.init_service "journal", Journal
@engine.register_participant(:alpha) do |wi|
@tracer << "alpha\n"
end
@@ -54,18 +54,16 @@
#fei = dotest(Test0, "alpha", 0.500, true)
li = LaunchItem.new Test0
fei = @engine.launch li
- sleep 0.200
+ sleep 0.500
get_journal.flush_buckets
- fn = get_journal.workdir + "/" + fei.wfid + ".journal"
+ assert_equal 1, get_error_count(fei.wfid)
- assert_equal get_error_count(fei.wfid), 1
-
@engine.register_participant(:nada) do |wi|
@tracer << "nada\n"
end
@engine.register_participant(:bravo) do |wi|
@tracer << "bravo\n"
@@ -75,11 +73,12 @@
get_journal.replay_at_last_error fei.wfid
sleep 1.0
- assert_equal @tracer.to_s, "alpha\nnada\nbravo"
+ assert_equal "alpha\nnada\nbravo", @tracer.to_s
+ fn = get_journal.workdir + "/" + fei.wfid + ".journal"
assert (not File.exist?(fn))
end
end