class TaskState
- TaskState
- Reference
- Object
Defined in:
crdo/task_state.crConstructors
Instance Method Summary
- #apply_snapshot(snapshot : TaskStateSnapshot)
- #has_run_successfully_once_since?(ts : Time)
- #has_stopped_once_since?(ts : Time)
- #keep!
- #last_start : Time?
- #last_status : Int32
- #last_stop : Time?
- #log_dn(ts)
- #mark_stopped(status : Int32, stop_time : Time)
- #next_scheduled_time(now : Time)
- #notify_overtime
- #parent_status : Hash(String, Bool)
- #retire!
- #retiring : Bool
- #run(start_time : Time, events : Channel(SchedulerEvent), test : Bool, clock : Clock)
- #run(args : Array(String), idx : Int32, start_time : Time, test : Bool, timeout : Time::Span | Nil = nil)
- #run_time(now : Time)
- #running? : Bool
- #should_notify_overtime?(now : Time)
- #started(start_time : Time)
- #state_snapshot
- #success?
- #task : Task
- #task=(task : Task)
- #terminate_running
- #to_json(json : JSON::Builder)
Constructor Detail
def self.new(task : Task, process_runner : TaskProcessRunner = TaskProcessRunner.new, mailer : TaskMailer = TaskMailer.new)
#
Instance Method Detail
def run(args : Array(String), idx : Int32, start_time : Time, test : Bool, timeout : Time::Span | Nil = nil)
#