test/functional/eft_6_concurrence.rb in ruote-2.1.8 vs test/functional/eft_6_concurrence.rb in ruote-2.1.9

- old
+ new

@@ -180,22 +180,25 @@ def test_concurrence_merge_type_isolate wi = run_concurrence({ :merge_type => :isolate }, false) - assert_equal(%w[ 0 1 params ], wi.fields.keys.collect { |k| k.to_s }.sort) + assert_equal( + %w[ 0 1 dispatched_at params ], + wi.fields.keys.collect { |k| k.to_s }.sort) + assert_equal({ 'ref' => 'alpha' }, wi.fields['params']) assert_equal(%w[ seen ], wi.fields['0'].keys) assert_equal(%w[ seen ], wi.fields['1'].keys) end def test_concurrence_merge_type_stack wi = run_concurrence({ :merge_type => :stack }, false) assert_equal( - %w[ params stack stack_attributes ], + %w[ dispatched_at params stack stack_attributes ], wi.fields.keys.collect { |k| k.to_s }.sort) assert_equal({ 'ref' => 'alpha' }, wi.fields['params']) assert_equal(%w[ seen ], wi.fields['stack'][0].keys) assert_equal(%w[ seen ], wi.fields['stack'][1].keys) @@ -228,15 +231,19 @@ wfid end def test_count + #noisy + wfid = run_test_count('cancel', false) #puts #logger.log.each { |e| p e } #puts assert_equal 1, logger.log.select { |e| e['action'] == 'cancel' }.size + + sleep 0.350 # since now dispatch_cancel occurs asynchronously... assert_equal 0, @alpha.size assert_equal 0, @bravo.size end