(allocations->peers allocations)
(build-stop-task-fn external-kill-flag started-task-ch)
(grouped-task? replica job-id task-id)
(input-task? replica job-id task-id)
(job->peers replica)
(job-allocations->peer-ids allocations job-id)
(job-peer-count replica job)
(leaf-tasks workflow root-task)
(messenger-slot-id replica job-id task-id peer-id)
(peer->allocated-job allocations id)
(promote-orphans replica group-id)
(remove-peers replica id)
Inputs: [replica :- os/Replica id :- os/PeerId]
Inputs: [replica :- os/Replica id :- os/PeerId]
(replica->job-peers replica job-id)
(root-tasks workflow leaf-task)
(src-peers replica ingress-tasks job-id)
(start-new-lifecycle old new diff state scheduler-event)
Inputs: [old :- os/Replica new :- os/Replica diff state scheduler-event :- os/PeerSchedulerEvent]
Inputs: [old :- os/Replica new :- os/Replica diff state scheduler-event :- os/PeerSchedulerEvent]
(start-task! lifecycle)
(state-task? replica job-id task-id)
(stop-lifecycle-peer-group! state scheduler-event)
(to-graph workflow)
(upstream-peers replica ingress-tasks job-id)
cljdoc is a website building & hosting documentation for Clojure/Script libraries
× close