Sha256: 81694763ab4bb7fecef91bb4e92857dfa06ce7438ee0f7b542139d8c5af27b08
Contents?: true
Size: 1.98 KB
Versions: 2
Compression:
Stored size: 1.98 KB
Contents
require File.expand_path(__FILE__).sub(%r(/test/.*), '/test/test_helper.rb') require File.expand_path(__FILE__).sub(%r(.*/test/), '').sub(/test_(.*)\.rb/,'\1') class TestTask < Test::Unit::TestCase def test_basic_task task = Task.setup do |s=""| (self + s).length end assert_equal 4, task.exec_on("1234") assert_equal 6, task.exec_on("1234","56") end def test_step task = Task.setup do |s=""| s.length end s = task.job('test', ['12']) s.clean assert_equal 2, s.run end def __test_benchmark tasks = [] wf = Module.new do extend Workflow self.name = "TestWF" 500.times do |i| task_name = "task_#{i}" last_task_name = "task_#{i-1}" if i == 0 task task_name => :array do [task_name] end else dep last_task_name task task_name => :array do step(last_task_name).load.push(task_name) end end end end Misc.benchmark(1000) do wf.job(:task_499) end end def test_dependencies_jobname_input wf = Module.new do extend Workflow self.name = "TestWF" input :name, :string, "Name", nil, jobname: true task :step1 => :string do |name| name end dep :step1 task :step2 => :string do step(:step1).load end dep :step1, jobname: nil task :step3 => :string do step(:step1).load end end Log.with_severity 0 do job = wf.job(:step2, nil, name: "Name") assert_equal "Name", job.run assert_equal "Name", job.step(:step1).name job = wf.job(:step2, "Name2", name: "Name") assert_equal "Name", job.run assert_equal "Name2", job.step(:step1).clean_name job = wf.job(:step3, "Name2", name: "Name") assert_equal "Name", job.run assert_equal "Name", job.step(:step1).name assert_equal "Name", wf.job(:step1, "Test", name: "Name").inputs[:name] end end end
Version data entries
2 entries across 2 versions & 1 rubygems
Version | Path |
---|---|
scout-gear-10.7.3 | test/scout/workflow/test_task.rb |
scout-gear-10.7.2 | test/scout/workflow/test_task.rb |