Sha256: 959bd815914b9aba24239623ab8553746649470d0dcf49888b0a29a744752e42
Contents?: true
Size: 1.93 KB
Versions: 53
Compression:
Stored size: 1.93 KB
Contents
module Workflow
attr_accessor :example_dir
def example_dir
@example_dir ||= self.libdir.examples
end
def examples
return {} unless self.libdir.examples.exists?
examples = {}
example_dir.glob("*/*").each do |example_dir|
example = File.basename(example_dir)
task_name = File.basename(File.dirname(example_dir))
examples[task_name] ||= []
examples[task_name] << example
end
IndiferentHash.setup examples
examples
end
def example(task_name, example)
task_info(task_name.to_sym)[:input_types].collect do |input,type|
next unless example_dir[task_name][example][input].exists?
[input, type, example_dir[task_name][example][input].find]
end.compact
end
def self.load_inputs(dir, input_names, input_types)
inputs = {}
dir = Path.setup(dir.dup)
input_names.each do |input|
file = dir[input].find
file = dir.glob(input.to_s + ".*").first if file.nil? or not file.exists?
Log.debug "Trying #{ input }: #{file}"
next unless file and file.exists?
case input_types[input]
when :tsv, :array, :text, :file
Log.debug "Pointing #{ input } to #{file}"
inputs[input.to_sym] = file
when :boolean
inputs[input.to_sym] = (file.read.strip == 'true')
else
Log.debug "Loading #{ input } from #{file}"
inputs[input.to_sym] = file.read.strip
end
end
IndiferentHash.setup(inputs)
end
def example_step(task_name, example)
inputs = {}
example(task_name, example).each do |input,type,file|
case type
when :tsv, :array, :text
Log.debug "Pointing #{ input } to #{file}"
inputs[input.to_sym] = file
when :boolean
inputs[input.to_sym] = (file.read.strip == 'true')
else
Log.debug "Loading #{ input } from #{file}"
inputs[input.to_sym] = file.read.strip
end
end
self.job(task_name, example, inputs)
end
end
Version data entries
53 entries across 53 versions & 1 rubygems