sisyphus.task — sisyphus 0.0.6

exception! clj

(exception! kafka task event throwable)

find-local! clj

(find-local! root [remote internal])

find-locals! clj

(find-locals! root locals)

first-command clj

(first-command commands)

full-name clj

Extract the string representation of the given keyword. This is an extension to the built-in name function which fails to return the full string representation for namespaced keywords.

join-commands clj

(join-commands commands)

load-task clj

(load-task path)

Load a task specification from the given path.

log! clj

(log! kafka task status message)

mount-map clj

(mount-map locals from to)

perform-task! clj

(perform-task! {:keys [storage kafka docker config state]} task)

Given a state containing a connection to both cloud storage and some docker service, execute the task specified by the given task map, downloading all inputs from cloud storage, executing the command in the specified container, and then uploading all outputs back to storage.

pull-input! clj

(pull-input! storage {:keys [bucket key archive local directory?]})

push-output! clj

(push-output! storage {:keys [local directory? archive bucket key]})

redirect-stdout clj

(redirect-stdout tokens stdout)

Translate the tokens of a command into a command that redirects stdout to the given file stdout

send! clj

(send! kafka task status message)

(send! kafka task status message topic)

severe! clj

(severe! kafka task status message)

split-key clj

(split-key key)

status! clj

(status! kafka task status message)