Tamas Nemeth 902f525307
[model]: Dataprocess instance entity to model datajob/jobflow runs (#4459)
* Initial model for dataprocess instance to model datajob/jobflow runs

* Fixing typos

* Removing dataprocessinstance from entity registry

* Add dataprocessinstance to entity registry
Adding DataprocessInstancekey aspect

* Fixing relationships

* Updating the model

* Removing EditableDataProcessInstanceProperties

* Makint try number optional

* Updating model

* Fixing typo

* visualizing job runs for a task

* add pagination

* show utc time on hover

* add dataset side

* dataprocessinstance > dataprocessinst

* add cypress test

* Removing jobs from DataFlowInfo.pdl as it should be part of another change if we really want it

* Adding missing files

* Fix moved import

* Remove duplicate import

* fixing yarn test

* Update DatasetRunsResolver.java

* Update TaskRunsResolver.java

* Update DatasetRunsResolver.java

* responding to comments

Co-authored-by: Gabe Lyons <itsgabelyons@gmail.com>
Co-authored-by: John Joyce <john@acryl.io>
2022-04-12 08:52:07 +02:00

55 lines
1.5 KiB
GraphQL

query getDataJob($urn: String!) {
dataJob(urn: $urn) {
...dataJobFields
parentFlow: relationships(input: { types: ["IsPartOf"], direction: OUTGOING, start: 0, count: 1 }) {
...fullRelationshipResults
}
incoming: relationships(
input: {
types: ["DownstreamOf", "Consumes", "Produces", "TrainedBy"]
direction: INCOMING
start: 0
count: 100
}
) {
...fullRelationshipResults
}
outgoing: relationships(
input: { types: ["DownstreamOf", "Consumes", "Produces"], direction: OUTGOING, start: 0, count: 100 }
) {
...fullRelationshipResults
}
upstream: lineage(input: { direction: UPSTREAM, start: 0, count: 100 }) {
...fullLineageResults
}
downstream: lineage(input: { direction: DOWNSTREAM, start: 0, count: 100 }) {
...fullLineageResults
}
status {
removed
}
runs(start: 0, count: 20) {
count
start
total
}
deprecation {
...deprecationFields
}
}
}
mutation updateDataJob($urn: String!, $input: DataJobUpdateInput!) {
updateDataJob(urn: $urn, input: $input) {
urn
}
}
query getDataJobRuns($urn: String!, $start: Int!, $count: Int!) {
dataJob(urn: $urn) {
runs(start: $start, count: $count) {
...runResults
}
}
}