datahub/datahub-web-react/src/graphql/ingestion.graphql at master · chris-celerdata/datahub · GitHub

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
query listIngestionSources($input: ListIngestionSourcesInput!) {
    listIngestionSources(input: $input) {
        start
        count
        total
        ingestionSources {
            ...ingestionSourceFields
            executions(start: 0, count: 1) {
                start
                count
                total
                executionRequests {
                    ...ingestionExecutionRequestFields
                }
            }
            ownership {
                ...ownershipFields
            }
        }
    }
}

query getNoOfIngestionSources($input: ListIngestionSourcesInput!) {
    listIngestionSources(input: $input) {
        total
    }
}

query getIngestionSource($urn: String!, $runStart: Int, $runCount: Int) {
    ingestionSource(urn: $urn) {
        ...ingestionSourceFields
        executions(start: $runStart, count: $runCount) {
            start
            count
            total
            executionRequests {
                ...ingestionExecutionRequestFields
            }
        }
        ownership {
            ...ownershipFields
        }
    }
}

query getIngestionExecutionRequest($urn: String!) {
    executionRequest(urn: $urn) {
        ...ingestionExecutionRequestFields
        source {
            ...ingestionSourceFields
        }
    }
}

query listIngestionExecutionRequests($input: ListExecutionRequestsInput!) {
    listExecutionRequests(input: $input) {
        start
        total
        count
        executionRequests {
            ...ingestionExecutionRequestFields
            source {
                ...ingestionSourceFields
                latestSuccessfulExecution {
                    ...minimalIngestionExecutionRequestFields
                }
            }
        }
    }
}

mutation createIngestionSource($input: UpdateIngestionSourceInput!) {
    createIngestionSource(input: $input)
}

mutation updateIngestionSource($urn: String!, $input: UpdateIngestionSourceInput!) {
    updateIngestionSource(urn: $urn, input: $input)
}

mutation deleteIngestionSource($urn: String!) {
    deleteIngestionSource(urn: $urn)
}

query listSecrets($input: ListSecretsInput!) {
    listSecrets(input: $input) {
        start
        count
        total
        secrets {
            urn
            name
            description
        }
    }
}

mutation createSecret($input: CreateSecretInput!) {
    createSecret(input: $input)
}

mutation updateSecret($input: UpdateSecretInput!) {
    updateSecret(input: $input)
}

mutation deleteSecret($urn: String!) {
    deleteSecret(urn: $urn)
}

mutation createIngestionExecutionRequest($input: CreateIngestionExecutionRequestInput!) {
    createIngestionExecutionRequest(input: $input)
}

mutation cancelIngestionExecutionRequest($input: CancelIngestionExecutionRequestInput!) {
    cancelIngestionExecutionRequest(input: $input)
}

mutation createTestConnectionRequest($input: CreateTestConnectionRequestInput!) {
    createTestConnectionRequest(input: $input)
}

mutation rollbackIngestion($input: RollbackIngestionInput!) {
    rollbackIngestion(input: $input)
}