Contents

module TestFlow
  extend Taskinator::Definition

  define_process :some_arg1, :some_arg2 do
    task :error_task, :continue_on_error => true

    task :the_task

    for_each :iterator do
      task :the_task
    end

    for_each :iterator, :sub_option => 1 do
      task :the_task
    end

    sequential do
      task :the_task
      task :the_task
      task :the_task
    end

    task :the_task

    concurrent do
      20.times do |i|
        task :the_task
      end
      task :the_task
    end

    task :the_task

    # invoke the specified sub process
    sub_process TestSubFlow

    job TestWorkerJob
  end

  def error_task(*args)
    raise "It's a huge problem!"
  end

  # note: arg1 and arg2 are passed in all the way from the
  #  definition#create_process method
  def iterator(arg1, arg2, options={})
    3.times do |i|
      yield [arg1, arg2, i]
    end
  end

  def the_task(*args)
    t = rand(1..11)
    Taskinator.logger.info "Executing task '#{task}' with [#{args}] for #{t} secs..."
    sleep 1 # 1
  end

  module TestSubFlow
    extend Taskinator::Definition

    define_process :some_arg1, :some_arg2 do
      task :the_task
      task :the_task
      task :the_task
    end

    def the_task(*args)
      t = rand(1..11)
      Taskinator.logger.info "Executing sub task '#{task}' with [#{args}] for #{t} secs..."
      sleep 1 # t
    end
  end

  module TestWorkerJob
    def self.perform(*args)
    end

    def perform(*args)
    end
  end

end

Version data entries

11 entries across 11 versions & 1 rubygems

Version	Path
taskinator-0.0.18	spec/support/test_flow.rb
taskinator-0.0.17	spec/support/test_flow.rb
taskinator-0.0.16	spec/support/test_flow.rb
taskinator-0.0.15	spec/support/test_flow.rb
taskinator-0.0.14	spec/support/test_flow.rb
taskinator-0.0.13	spec/support/test_flow.rb
taskinator-0.0.12	spec/support/test_flow.rb
taskinator-0.0.11	spec/support/test_flow.rb
taskinator-0.0.10	spec/support/test_flow.rb
taskinator-0.0.9	spec/support/test_flow.rb
taskinator-0.0.8	spec/support/test_flow.rb