Sha256: dcac0d4f5475d45bf16a74a7d0333f795776b4b03d0ca5271a7ea873bf3ca2b3
Contents?: true
Size: 1.49 KB
Versions: 27
Compression:
Stored size: 1.49 KB
Contents
module TestFlow
extend Taskinator::Definition
define_process :some_arg1, :some_arg2 do
# TODO: add support for "continue_on_error"
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
27 entries across 27 versions & 1 rubygems