Differential D6214 Diff 30519 python_modules/dagster-graphql/dagster_graphql/implementation/fetch_jobs.py
Changeset View
Changeset View
Standalone View
Standalone View
python_modules/dagster-graphql/dagster_graphql/implementation/fetch_jobs.py
| Show All 40 Lines | def get_job_state_or_error(graphene_info, selector): | ||||
| external_job = repository.get_external_job(selector.job_name) | external_job = repository.get_external_job(selector.job_name) | ||||
| if not external_job or not isinstance(external_job, (ExternalSensor, ExternalSchedule)): | if not external_job or not isinstance(external_job, (ExternalSensor, ExternalSchedule)): | ||||
| raise UserFacingGraphQLError( | raise UserFacingGraphQLError( | ||||
| graphene_info.schema.type_named("JobNotFoundError")(selector.job_name) | graphene_info.schema.type_named("JobNotFoundError")(selector.job_name) | ||||
| ) | ) | ||||
| job_state = graphene_info.context.instance.get_job_state(external_job.get_external_origin_id()) | job_state = graphene_info.context.instance.get_job_state(external_job.get_external_origin_id()) | ||||
| if not job_state: | if not job_state: | ||||
| job_state = external_job.get_default_job_state() | job_state = external_job.get_default_job_state(graphene_info.context.instance) | ||||
| return graphene_info.schema.type_named("JobState")(job_state=job_state) | return graphene_info.schema.type_named("JobState")(job_state=job_state) | ||||