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)

input-task?

(input-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)

promote-orphans

(promote-orphans replica group-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)