class

TaskState

Inherits Reference < Object

Constructors

new(task : Task, process_runner : TaskProcessRunner = TaskProcessRunner.new, mailer : TaskMailer = TaskMailer.new)
Source

Instance methods

apply_snapshot(snapshot : TaskStateSnapshot)
Source
has_run_successfully_once_since?(ts : Time)
Source
has_stopped_once_since?(ts : Time)
Source
keep!
Source
last_start
Source
last_status
Source
last_stop
Source
log_dn(ts)
Source
mark_stopped(status : Int32, stop_time : Time)
Source
next_scheduled_time(now : Time)
Source
notify_overtime
Source
parent_status
Source
retire!
Source
retiring
Source
run(start_time : Time, events : Channel(SchedulerEvent), test : Bool, clock : Clock)
Source
run(args : Array(String), idx : Int32, start_time : Time, test : Bool, timeout : Time::Span | Nil = nil)
Source
run_time(now : Time)
Source
running?
Source
should_notify_overtime?(now : Time)
Source
started(start_time : Time)
Source
state_snapshot
Source
success?
Source
task
Source
task=(task : Task)
Source
terminate_running
Source
to_json(json : JSON::Builder)
Source