2022-01-27 10:33:12 -08:00
|
|
|
query listIngestionSources($input: ListIngestionSourcesInput!) {
|
|
|
|
listIngestionSources(input: $input) {
|
|
|
|
start
|
|
|
|
count
|
|
|
|
total
|
|
|
|
ingestionSources {
|
|
|
|
urn
|
|
|
|
name
|
|
|
|
type
|
|
|
|
config {
|
|
|
|
recipe
|
|
|
|
version
|
|
|
|
executorId
|
2022-08-29 16:39:14 -04:00
|
|
|
debugMode
|
2022-01-27 10:33:12 -08:00
|
|
|
}
|
|
|
|
schedule {
|
|
|
|
interval
|
|
|
|
timezone
|
|
|
|
}
|
|
|
|
executions(start: 0, count: 1) {
|
|
|
|
start
|
|
|
|
count
|
|
|
|
total
|
|
|
|
executionRequests {
|
|
|
|
urn
|
2022-08-08 14:33:57 -07:00
|
|
|
id
|
2022-01-27 10:33:12 -08:00
|
|
|
input {
|
|
|
|
requestedAt
|
|
|
|
}
|
|
|
|
result {
|
|
|
|
status
|
|
|
|
startTimeMs
|
|
|
|
durationMs
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
query getIngestionSource($urn: String!, $runStart: Int, $runCount: Int) {
|
|
|
|
ingestionSource(urn: $urn) {
|
|
|
|
urn
|
|
|
|
name
|
|
|
|
type
|
|
|
|
config {
|
|
|
|
recipe
|
|
|
|
version
|
|
|
|
executorId
|
2022-08-29 16:39:14 -04:00
|
|
|
debugMode
|
2022-01-27 10:33:12 -08:00
|
|
|
}
|
|
|
|
schedule {
|
|
|
|
interval
|
|
|
|
timezone
|
|
|
|
}
|
|
|
|
executions(start: $runStart, count: $runCount) {
|
|
|
|
start
|
|
|
|
count
|
|
|
|
total
|
|
|
|
executionRequests {
|
|
|
|
urn
|
2022-08-08 14:33:57 -07:00
|
|
|
id
|
2022-01-27 10:33:12 -08:00
|
|
|
input {
|
|
|
|
requestedAt
|
|
|
|
source {
|
|
|
|
type
|
|
|
|
}
|
|
|
|
}
|
|
|
|
result {
|
|
|
|
status
|
|
|
|
startTimeMs
|
|
|
|
durationMs
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
query getIngestionExecutionRequest($urn: String!) {
|
|
|
|
executionRequest(urn: $urn) {
|
|
|
|
urn
|
2022-08-08 14:33:57 -07:00
|
|
|
id
|
2022-01-27 10:33:12 -08:00
|
|
|
input {
|
|
|
|
source {
|
|
|
|
type
|
|
|
|
}
|
|
|
|
}
|
|
|
|
result {
|
|
|
|
status
|
|
|
|
startTimeMs
|
|
|
|
durationMs
|
|
|
|
report
|
2022-08-01 12:12:02 -04:00
|
|
|
structuredReport {
|
|
|
|
type
|
|
|
|
serializedValue
|
|
|
|
}
|
2022-01-27 10:33:12 -08:00
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
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 deleteSecret($urn: String!) {
|
|
|
|
deleteSecret(urn: $urn)
|
|
|
|
}
|
|
|
|
|
|
|
|
mutation createIngestionExecutionRequest($input: CreateIngestionExecutionRequestInput!) {
|
|
|
|
createIngestionExecutionRequest(input: $input)
|
|
|
|
}
|
|
|
|
|
|
|
|
mutation cancelIngestionExecutionRequest($input: CancelIngestionExecutionRequestInput!) {
|
|
|
|
cancelIngestionExecutionRequest(input: $input)
|
|
|
|
}
|
2022-08-01 12:12:02 -04:00
|
|
|
|
|
|
|
mutation createTestConnectionRequest($input: CreateTestConnectionRequestInput!) {
|
|
|
|
createTestConnectionRequest(input: $input)
|
|
|
|
}
|