Skip to content

Instantly share code, notes, and snippets.

@kinow
Last active May 24, 2020 23:09
Show Gist options
  • Save kinow/772c59a938fa74ee6cd8fc72f6e18aed to your computer and use it in GitHub Desktop.
Save kinow/772c59a938fa74ee6cd8fc72f6e18aed to your computer and use it in GitHub Desktop.
subscription OnWorkflowDeltasData($workflowId: ID) {
deltas(workflows: [$workflowId], stripNull: true) {
...WorkflowTreeDeltas
__typename
}
}
fragment WorkflowTreeDeltas on Deltas {
id
shutdown
added {
...WorkflowTreeAddedData
__typename
}
updated {
...WorkflowTreeUpdatedData
__typename
}
pruned {
...WorkflowTreePrunedData
__typename
}
__typename
}
fragment WorkflowTreeAddedData on Added {
workflow {
...WorkflowData
cyclePoints: familyProxies(ids: ["root"], ghosts: true) {
cyclePoint
__typename
}
taskProxies(sort: {keys: ["cyclePoint"]}, ghosts: true) {
...TaskProxyData
jobs(sort: {keys: ["submit_num"], reverse: true}) {
...JobData
__typename
}
__typename
}
familyProxies(exids: ["root"], sort: {keys: ["firstParent"]}, ghosts: true) {
...FamilyProxyData
__typename
}
__typename
}
cyclePoints: familyProxies(ids: ["root"], ghosts: true) {
cyclePoint
__typename
}
familyProxies(exids: ["root"], sort: {keys: ["firstParent"]}, ghosts: true) {
...FamilyProxyData
__typename
}
taskProxies(sort: {keys: ["cyclePoint"]}, ghosts: true) {
...TaskProxyData
__typename
}
jobs(sort: {keys: ["submit_num"], reverse: true}) {
...JobData
__typename
}
__typename
}
fragment WorkflowTreeUpdatedData on Updated {
taskProxies(sort: {keys: ["cyclePoint"]}, ghosts: true) {
...TaskProxyData
__typename
}
jobs(sort: {keys: ["submit_num"], reverse: true}) {
...JobData
__typename
}
familyProxies(exids: ["root"], sort: {keys: ["firstParent"]}, ghosts: true) {
...FamilyProxyData
__typename
}
__typename
}
fragment WorkflowTreePrunedData on Pruned {
jobs
taskProxies
familyProxies
__typename
}
fragment WorkflowData on Workflow {
id
name
status
owner
host
port
__typename
}
fragment FamilyProxyData on FamilyProxy {
id
name
state
cyclePoint
firstParent {
id
name
cyclePoint
state
__typename
}
__typename
}
fragment TaskProxyData on TaskProxy {
id
name
state
isHeld
cyclePoint
latestMessage
firstParent {
id
name
cyclePoint
state
__typename
}
task {
meanElapsedTime
name
__typename
}
__typename
}
fragment JobData on Job {
id
firstParent: taskProxy {
id
__typename
}
batchSysName
batchSysJobId
host
startedTime
submittedTime
finishedTime
state
submitNum
__typename
}
@kinow
Copy link
Author

kinow commented May 24, 2020

Original query doesn't have __typename, that gets added by ApolloClient.

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