flowing.core — flowing 0.1.0

defstep clj macro

(defstep step-name args & body)

defworkflow clj macro

(defworkflow wf-name & steps)

deref-deep clj

(deref-deep ref)

inputs clj

(inputs step)

link clj macro

(link from to)

output-ref clj

(output-ref step)

ref? clj

(ref? val)

step clj macro

(step step-name args & body)

step-name clj

(step-name step)

wait-for-output clj

(wait-for-output step)

wait-for-workflow clj

(wait-for-workflow workflow)

workflow clj

(workflow & steps)

Define a workflow using a series of (defstep) and (link) calls

workflow-steps clj

(workflow-steps wf)