adds job to the spawn

clears the program and past spawn information

returns the number of jobs

counts all running spawns

creates a run handler

(create-handler (assoc defaults :type :basic) (create-spawn)) => fn?

creates a basic handler

creates a constant handler

creates a new spawn

(-> (create-spawn (merge defaults {:interval 1}) “spawn.1”) (spawn-info)) => {:id “spawn.1”, :status :created, :duration “0ms”, :jobs {:submitted 0 :succeeded 0 :errored 0 :waiting 0}, :state nil}

returns earliest created spawn

returns all running spawns

retrieves a job given key

(-> (doto (create-spawn) (add-job “j.1” {:id “j.1”}))

(get-job "j.1"))

=> {:id “j.1”}

gets the program given runtime and program-id

(get-program |rt3| :test-program) => {}

gets the spawn prop given key

(-> (create-spawn) (get-props :submitted)) => 0

gets running spawn with id

gets the global state for the program-id

(get-state |rt3| :test-program) => {}

handles the

(let ret (h/incomplete) job {:id “j.0” :time 0 :return ret} spawn (doto (create-spawn) (add-job “j.0” job)) result {:task (handler-run defaults spawn job)} (assoc result :return @ret :meta @(:output spawn))) => (contains-in {:task “j.0” 0 :return nil :meta {:status :success, :data nil, :exception nil, :time 0, :start integer? :end integer?}})

kills all the running tasks

(-> (doto |rt3| (kill-all :test-program)) (count-spawn :test-program)) => 0

stops a spawn and all jobs

(kill-spawn |rt3| :test-program “s1”) => spawn?

returns the latest active or past spawn

returns latest created spawn

returns the most recently stopped spawn

lists all job ids

list all jobs

lists all running spawns

lists all stopped spawns

removes a job given key

constructs and starts a spawn loop

calculates the timing for the next schedule

(schedule-timing :constant {:interval 1000} 500 635) => 1500 865

sends the result to spawn output

updates the spawn props

(-> (create-spawn) (set-props :submitted inc :errored 4 :started true) (select-keys :submitted :errored :started)) => {:submitted 1, :errored 4, :started true}

returns the spawn info

creates a spawn loop

helper function to move spawn from :running to :past

returns the spawn status

checks that object is a spawn

stops all the running tasks

(-> (doto |rt3| (stop-all :test-program)) (count-spawn :test-program)) => 0

stop a spawn and waits for jobs to finish

updates a job given key

wrapper for the schedule function