Changeset View
Changeset View
Standalone View
Standalone View
js_modules/dagit/src/schedules/ScheduleUtils.tsx
Show All 32 Lines | fragment ScheduleStateFragment on ScheduleState { | ||||
ticks(limit: 1) { | ticks(limit: 1) { | ||||
tickId | tickId | ||||
status | status | ||||
timestamp | timestamp | ||||
tickSpecificData { | tickSpecificData { | ||||
__typename | __typename | ||||
... on ScheduleTickSuccessData { | ... on ScheduleTickSuccessData { | ||||
run { | run { | ||||
id | |||||
pipelineName | pipelineName | ||||
status | status | ||||
runId | runId | ||||
} | } | ||||
} | } | ||||
... on ScheduleTickFailureData { | ... on ScheduleTickFailureData { | ||||
error { | error { | ||||
...PythonErrorFragment | ...PythonErrorFragment | ||||
} | } | ||||
} | } | ||||
} | } | ||||
} | } | ||||
runsCount | runsCount | ||||
runs(limit: 10) { | runs(limit: 10) { | ||||
id | |||||
runId | runId | ||||
tags { | tags { | ||||
key | key | ||||
value | value | ||||
} | } | ||||
pipelineName | pipelineName | ||||
status | status | ||||
} | } | ||||
ticksCount | ticksCount | ||||
status | status | ||||
} | } | ||||
${PythonErrorInfo.fragments.PythonErrorFragment} | ${PythonErrorInfo.fragments.PythonErrorFragment} | ||||
`; | `; | ||||
export const SCHEDULE_DEFINITION_FRAGMENT = gql` | export const SCHEDULE_DEFINITION_FRAGMENT = gql` | ||||
fragment ScheduleDefinitionFragment on ScheduleDefinition { | fragment ScheduleDefinitionFragment on ScheduleDefinition { | ||||
id | |||||
name | name | ||||
cronSchedule | cronSchedule | ||||
pipelineName | pipelineName | ||||
solidSelection | solidSelection | ||||
mode | mode | ||||
partitionSet { | partitionSet { | ||||
name | name | ||||
} | } | ||||
scheduleState { | scheduleState { | ||||
id | |||||
...ScheduleStateFragment | ...ScheduleStateFragment | ||||
} | } | ||||
} | } | ||||
${SCHEDULE_STATE_FRAGMENT} | ${SCHEDULE_STATE_FRAGMENT} | ||||
`; | `; | ||||
export const SCHEDULES_ROOT_QUERY = gql` | export const SCHEDULES_ROOT_QUERY = gql` | ||||
query SchedulesRootQuery($repositorySelector: RepositorySelector!) { | query SchedulesRootQuery($repositorySelector: RepositorySelector!) { | ||||
repositoryOrError(repositorySelector: $repositorySelector) { | repositoryOrError(repositorySelector: $repositorySelector) { | ||||
__typename | __typename | ||||
... on Repository { | ... on Repository { | ||||
name | name | ||||
id | id | ||||
...RepositoryInfoFragment | ...RepositoryInfoFragment | ||||
} | } | ||||
...PythonErrorFragment | ...PythonErrorFragment | ||||
} | } | ||||
scheduler { | scheduler { | ||||
...SchedulerFragment | ...SchedulerFragment | ||||
} | } | ||||
scheduleDefinitionsOrError(repositorySelector: $repositorySelector) { | scheduleDefinitionsOrError(repositorySelector: $repositorySelector) { | ||||
... on ScheduleDefinitions { | ... on ScheduleDefinitions { | ||||
results { | results { | ||||
id | |||||
...ScheduleDefinitionFragment | ...ScheduleDefinitionFragment | ||||
} | } | ||||
} | } | ||||
...PythonErrorFragment | ...PythonErrorFragment | ||||
} | } | ||||
scheduleStatesOrError(repositorySelector: $repositorySelector, withNoScheduleDefinition: true) { | scheduleStatesOrError(repositorySelector: $repositorySelector, withNoScheduleDefinition: true) { | ||||
__typename | __typename | ||||
... on ScheduleStates { | ... on ScheduleStates { | ||||
results { | results { | ||||
id | |||||
...ScheduleStateFragment | ...ScheduleStateFragment | ||||
} | } | ||||
} | } | ||||
...PythonErrorFragment | ...PythonErrorFragment | ||||
} | } | ||||
} | } | ||||
${SCHEDULE_DEFINITION_FRAGMENT} | ${SCHEDULE_DEFINITION_FRAGMENT} | ||||
Show All 28 Lines |