Module: Rukawa

Defined in:

lib/rukawa.rb,
lib/rukawa/cli.rb,
lib/rukawa/dag.rb,
lib/rukawa/job.rb,
lib/rukawa/errors.rb,
lib/rukawa/remote.rb,
lib/rukawa/runner.rb,
lib/rukawa/context.rb,
lib/rukawa/job_net.rb,
lib/rukawa/version.rb,
lib/rukawa/wrapper.rb,
lib/rukawa/overview.rb,
lib/rukawa/dependency.rb,
lib/rukawa/abstract_job.rb,
lib/rukawa/builtins/base.rb,
lib/rukawa/configuration.rb,
lib/rukawa/builtins/shell.rb,
lib/rukawa/builtins/embulk.rb,
lib/rukawa/builtins/waiter.rb,
lib/rukawa/wrapper/active_job.rb,
lib/rukawa/remote/status_store.rb

Defined Under Namespace

Modules: Builtins, Dependency, Overview, Remote, State, Wrapper Classes: AbstractJob, Cli, Configuration, Context, Dag, DependencyUnsatisfied, GraphConfig, GraphNodeConfig, Job, JobNet, Runner

Constant Summary

VERSION =

"0.9.2"

Class Method Summary

• .config ⇒ Object
• .configure {|config| ... } ⇒ Object
• .load_jobs ⇒ Object
• .logger ⇒ Object

Class Method Details

.config ⇒ Object

# File 'lib/rukawa.rb', line 13

def config
  Configuration.instance
end

.configure {|config| ... } ⇒ Object

Yields:

• (config)

# File 'lib/rukawa.rb', line 9

def configure
  yield config
end

.load_jobs ⇒ Object

# File 'lib/rukawa.rb', line 17

def load_jobs
  job_dirs = config.job_dirs.map { |d| File.expand_path(d) }.uniq
  job_dirs.each do |dir|
    Dir.glob(File.join(dir, "**/*.rb")) { |f| load f }
  end
end

.logger ⇒ Object

# File 'lib/rukawa.rb', line 5

def logger
  config.logger
end