Differential D6164 Diff 30546 python_modules/dagster-graphql/dagster_graphql/schema/__init__.py

Changeset View

Standalone View

python_modules/dagster-graphql/dagster_graphql/schema/init.py

	from dagster_graphql import dauphin			import graphene

				from .roots.mutation import GrapheneMutation
				from .roots.query import GrapheneQuery
				from .roots.subscription import GrapheneSubscription

	def create_schema():
	# dauphin depends on import-based side effects			def types():
	# pylint: disable=W0611			from .logs import types as log_types
	from . import (			from .pipelines import types as pipelines_types
	assets,			from .roots import types as roots_types
	config_types,			from .schedules import types as schedules_types
	dagster_types,			from .asset_key import GrapheneAssetKey
	errors,			from .backfill import GraphenePartitionBackfillResult, GraphenePartitionBackfillSuccess
	execution,			from .config_type_or_error import GrapheneConfigTypeOrError
	external,			from .config_types import types as config_types
	jobs,			from .dagster_types import types as dagster_types_types
	paging,			from .errors import types as errors_types
	partition_sets,			from .execution import types as execution_types
	pipelines,			from .external import types as external_types
	roots,			from .inputs import types as inputs_types
	runs,			from .instance import (
	schedules,			GrapheneDaemonHealth,
	sensors,			GrapheneDaemonStatus,
				GrapheneInstance,
				GrapheneRunLauncher,
				)
				from .jobs import types as jobs_types
				from .metadata import GrapheneMetadataItemDefinition
				from .paging import GrapheneCursor
				from .partition_sets import types as partition_sets_types
				from .repository_origin import GrapheneRepositoryOrigin, GrapheneRepositoryMetadata
				from .run_config import GrapheneRunConfigSchema, GrapheneRunConfigSchemaOrError
				from .runs import types as runs_types
				from .sensors import types as sensors_types
				from .solids import types as solids_types
				from .tags import GraphenePipelineTag, GraphenePipelineTagAndValues
				from .used_solid import GrapheneSolidInvocationSite, GrapheneUsedSolid

				return (
				log_types()
				+ pipelines_types()
				+ roots_types()
				+ schedules_types()
				+ [GrapheneAssetKey]
				+ [GraphenePartitionBackfillResult, GraphenePartitionBackfillSuccess]
				+ [GrapheneConfigTypeOrError]
				+ config_types
				+ dagster_types_types
				+ errors_types
				+ execution_types
				+ external_types
				+ inputs_types
				+ [GrapheneDaemonHealth, GrapheneDaemonStatus, GrapheneInstance, GrapheneRunLauncher]
				+ jobs_types
				+ [GrapheneMetadataItemDefinition]
				+ [GrapheneCursor]
				+ partition_sets_types
				+ [GrapheneRepositoryOrigin, GrapheneRepositoryMetadata]
				+ [GrapheneRunConfigSchema, GrapheneRunConfigSchemaOrError]
				+ runs_types
				+ sensors_types
				+ solids_types
				+ [GraphenePipelineTag, GraphenePipelineTagAndValues]
				+ [GrapheneSolidInvocationSite, GrapheneUsedSolid]
				maxAuthorUnsubmitted Done Inline Actions Previously we were relying on the implicit registry functionality / metaclass magic provided by Dauphin to load all of the types in the schema; this moves us to be explicit, which may or may not be better, but more importantly allows pieces of the schema to be imported by other projects without having to pull in the entire registry max: Previously we were relying on the implicit registry functionality / metaclass magic provided by…
	)			)

	return dauphin.create_schema()
				def create_schema():
				return graphene.Schema(
				query=GrapheneQuery,
				mutation=GrapheneMutation,
				subscription=GrapheneSubscription,
				types=types(),
				)