Skip to content

Instantly share code, notes, and snippets.

@kinow
Created August 2, 2021 04:24
Show Gist options
  • Select an option

  • Save kinow/1eb802847413c3ef3873ca4b3ee38eac to your computer and use it in GitHub Desktop.

Select an option

Save kinow/1eb802847413c3ef3873ca4b3ee38eac to your computer and use it in GitHub Desktop.
query now
subscription OnWorkflowTreeDeltasData($workflowId: ID) {
deltas(workflows: [$workflowId], stripNull: true) {
...WorkflowTreeDeltas
__typename
}
}
fragment WorkflowTreeDeltas on Deltas {
id
added {
...WorkflowTreeAddedData
__typename
}
updated {
...WorkflowTreeUpdatedData
__typename
}
pruned {
...WorkflowTreePrunedData
__typename
}
__typename
}
fragment WorkflowTreeAddedData on Added {
workflow {
...WorkflowData
__typename
}
cyclePoints: familyProxies(ids: ["root"], ghosts: true) {
...CyclePointData
__typename
}
familyProxies(exids: ["root"], sort: {keys: ["name"]}, ghosts: true) {
...FamilyProxyData
__typename
}
taskProxies(sort: {keys: ["cyclePoint"], reverse: false}, ghosts: true) {
...TaskProxyData
__typename
}
jobs(sort: {keys: ["submit_num"], reverse: true}) {
...JobData
__typename
}
__typename
}
fragment WorkflowTreeUpdatedData on Updated {
taskProxies(ghosts: true) {
...TaskProxyData
__typename
}
jobs {
...JobData
__typename
}
familyProxies(exids: ["root"], ghosts: true) {
...FamilyProxyData
__typename
}
__typename
}
fragment WorkflowTreePrunedData on Pruned {
jobs
taskProxies
familyProxies
__typename
}
fragment WorkflowData on Workflow {
id
name
status
owner
host
port
stateTotals
latestStateTasks(
states: ["failed", "preparing", "submit-failed", "submitted", "running"]
)
__typename
}
fragment CyclePointData on FamilyProxy {
id
cyclePoint
__typename
}
fragment FamilyProxyData on FamilyProxy {
id
name
state
cyclePoint
firstParent {
id
name
cyclePoint
state
__typename
}
__typename
}
fragment TaskProxyData on TaskProxy {
id
name
state
isHeld
isQueued
isRunahead
cyclePoint
firstParent {
id
name
cyclePoint
state
__typename
}
task {
meanElapsedTime
name
__typename
}
__typename
}
fragment JobData on Job {
id
firstParent: taskProxy {
id
__typename
}
jobRunnerName
jobId
platform
startedTime
submittedTime
finishedTime
state
submitNum
taskProxy {
outputs(satisfied: true, sort: {keys: ["time"], reverse: true}) {
label
message
__typename
}
__typename
}
__typename
}
@kinow
Copy link
Author

kinow commented Aug 2, 2021

Five:

[scheduling]
  cycling mode = integer
  initial cycle point = 1
  [[queues]]
     [[[default]]]
       limit = 1
  [[graph]]
    R1 = "prep => foo"
    P1 = "foo[-P1] => foo => bar"

[runtime]
  [[root]]
      script="sleep 5"
  [[prep]]
  [[foo]]
  [[bar]]

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment