onyx.log.commands.common
allocations->peers
(allocations->peers allocations)
build-stop-task-fn
(build-stop-task-fn external-kill-flag started-task-ch)
grouped-task?
(grouped-task? replica job-id task-id)
job->peers
(job->peers replica)
job-allocations->peer-ids
(job-allocations->peer-ids allocations job-id)
job-peer-count
(job-peer-count replica job)
leaf-tasks
(leaf-tasks workflow root-task)
messenger-slot-id
(messenger-slot-id replica job-id task-id peer-id)
peer->allocated-job
(peer->allocated-job allocations id)
remove-peers
(remove-peers replica id)
Inputs: [replica :- os/Replica id :- os/PeerId]
replica->job-peers
(replica->job-peers replica job-id)
root-tasks
(root-tasks workflow leaf-task)
src-peers
(src-peers replica ingress-tasks job-id)
start-new-lifecycle
(start-new-lifecycle old new diff state scheduler-event)
Inputs: [old :- os/Replica new :- os/Replica diff state scheduler-event :- os/PeerSchedulerEvent]
start-task!
(start-task! lifecycle)
state-task?
(state-task? replica job-id task-id)
stop-lifecycle-peer-group!
(stop-lifecycle-peer-group! state scheduler-event)
to-graph
(to-graph workflow)
upstream-peers
(upstream-peers replica ingress-tasks job-id)