class Neph::Job

Included Modules

Defined in:

neph/job/job.cr

Constant Summary

DONE = 2
ERROR = 3
RUNNING = 1
SKIP = 4
TICK_CHARS = "⠁⠁⠉⠙⠚⠒⠂⠂⠒⠲⠴⠤⠄⠄⠤⠠⠠⠤⠦⠖⠒⠐⠐⠒⠓⠋⠉⠈⠈ "
WAITING = 0

Constructors

Instance Method Summary

Instance methods inherited from module Neph

format_time(time) format_time, log(msg : String, force : Bool = false) log, log_err log_err, log_ln(msg : String, force : Bool = false) log_ln, log_out log_out, neph_dir neph_dir, ready_dir ready_dir

Instance methods inherited from module Neph::Message

error(msg : String) error

Instance methods inherited from module Neph::Parser

add_sub_job(config : YHash, job : Job, sub_job_name : String, env : String | Nil)
add_sub_job(config : YHash, job : Job, sub_job : String)
add_sub_job(config : YHash, job : Job, sub_job : YHash)
add_sub_job
, create_job(config : Hash(YAML::Any, YAML::Any), job_name : String, parent_job : Job | Nil = nil) : Job create_job, parse_yaml(job_name : String, path : String) : Job
parse_yaml(path : String) : Hash(YAML::Any, YAML::Any)
parse_yaml
, source_files(path : String) : Array(String) source_files

Constructor Detail

def self.new(name : String, commands : Array(String), before : Array(String), after : Array(String), parent_job : Job | Nil) #

[View source]

Instance Method Detail

def add_sources(source_files : Array(String)) #

[View source]
def add_sub_job(job : Job, env : String | Nil) #

[View source]
def after : Array(String) #

[View source]
def before : Array(String) #

[View source]
def clean_tmp #

[View source]
def commands : Array(String) #

[View source]
def create_dir #

[View source]
def current_command : String #

[View source]
def depends_on : Array(Job) #

[View source]
def dir : String #

[View source]
def dir=(dir : String) #

[View source]
def done? : Bool #

[View source]
def done_command : Int32 #

[View source]
def elapsed_time : String #

[View source]
def env : String | Nil #

[View source]
def env=(env : String | Nil) #

[View source]
def exec(channel : Channel(Nil) | Nil = nil) #

[View source]
def exec_commands(commands : Array(String), stdout, stderr) #

[View source]
def exec_self #

[View source]
def exec_sub_job_parallel #

[View source]
def exec_sub_job_sequential #

[View source]
def file_tail(path : String) : String #

[View source]
def get_progress : String #

[View source]
def has_parent_job?(sub_job_name : String) : Bool #

[View source]
def hide : Bool #

[View source]
def hide=(hide : Bool) #

[View source]
def ignore_error : Bool #

[View source]
def ignore_error=(ignore_error : Bool) #

[View source]
def log_dir : String #

[View source]
def name : String #

[View source]
def num_of_done_jobs #

[View source]
def num_of_jobs #

[View source]
def prepare_env #

[View source]
def progress : Int32 #

[View source]
def progress_max : Int32 #

[View source]
def progress_msg : String #

[View source]
def progress_percent : Int32 #

[View source]
def shown_command : String #

[View source]
def src : Array(String) #

[View source]
def src=(src : Array(String)) #

[View source]
def status_changed? : Bool #

[View source]
def status_code : Int32 #

[View source]
def status_msg(indent_spaces = "") #

[View source]
def status_msg_ci #

[View source]
def time_msg : String #

[View source]
def tmp_dir : String #

[View source]
def tmp_file(source : String) : String #

[View source]
def to_s(indent = 0) : String #
Description copied from class Object

Returns a nicely readable and concise string representation of this object, typically intended for users.

This method should usually not be overridden. It delegates to #to_s(IO) which can be overridden for custom implementations.

Also see #inspect.


[View source]
def to_s_ci : String #

[View source]
def up_to_date? : Bool #

TODO should be fixed


[View source]
def ws_dir : String #

[View source]