Differential D4697 Diff 23458 python_modules/dagster-graphql/dagster_graphql/schema/runs.py

Changeset View

Standalone View

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

from __future__ import absolute_import		from __future__ import absolute_import

import logging		import logging

import yaml		import yaml
from dagster_graphql import dauphin		from dagster_graphql import dauphin
from dagster_graphql.implementation.fetch_assets import get_assets_for_run_id		from dagster_graphql.implementation.fetch_assets import get_assets_for_run_id
from dagster_graphql.implementation.fetch_pipelines import get_pipeline_reference_or_raise		from dagster_graphql.implementation.fetch_pipelines import get_pipeline_reference_or_raise
from dagster_graphql.implementation.fetch_runs import get_stats, get_step_stats		from dagster_graphql.implementation.fetch_runs import get_stats, get_step_stats

from dagster import PipelineRun, check, seven		from dagster import PipelineRun, check, seven
from dagster.core.definitions.events import (		from dagster.core.definitions.events import (
		AddressMetadataEntryData,
EventMetadataEntry,		EventMetadataEntry,
FloatMetadataEntryData,		FloatMetadataEntryData,
JsonMetadataEntryData,		JsonMetadataEntryData,
MarkdownMetadataEntryData,		MarkdownMetadataEntryData,
PathMetadataEntryData,		PathMetadataEntryData,
PythonArtifactMetadataEntryData,		PythonArtifactMetadataEntryData,
TextMetadataEntryData,		TextMetadataEntryData,
UrlMetadataEntryData,		UrlMetadataEntryData,
▲ Show 20 Lines • Show All 403 Lines • ▼ Show 20 Lines
class DauphinEventPathMetadataEntry(dauphin.ObjectType):		class DauphinEventPathMetadataEntry(dauphin.ObjectType):
class Meta(object):		class Meta(object):
name = "EventPathMetadataEntry"		name = "EventPathMetadataEntry"
interfaces = (DauphinEventMetadataEntry,)		interfaces = (DauphinEventMetadataEntry,)

path = dauphin.NonNull(dauphin.String)		path = dauphin.NonNull(dauphin.String)


		class DauphinEventAddressMetadataEntry(dauphin.ObjectType):
		class Meta(object):
		name = "EventAddressMetadataEntry"
		interfaces = (DauphinEventMetadataEntry,)

		address = dauphin.Field(dauphin.String)


class DauphinEventJsonMetadataEntry(dauphin.ObjectType):		class DauphinEventJsonMetadataEntry(dauphin.ObjectType):
class Meta(object):		class Meta(object):
name = "EventJsonMetadataEntry"		name = "EventJsonMetadataEntry"
interfaces = (DauphinEventMetadataEntry,)		interfaces = (DauphinEventMetadataEntry,)

jsonString = dauphin.NonNull(dauphin.String)		jsonString = dauphin.NonNull(dauphin.String)


▲ Show 20 Lines • Show All 42 Lines • ▼ Show 20 Lines	def iterate_metadata_entries(metadata_entries):
check.list_param(metadata_entries, "metadata_entries", of_type=EventMetadataEntry)		check.list_param(metadata_entries, "metadata_entries", of_type=EventMetadataEntry)
for metadata_entry in metadata_entries:		for metadata_entry in metadata_entries:
if isinstance(metadata_entry.entry_data, PathMetadataEntryData):		if isinstance(metadata_entry.entry_data, PathMetadataEntryData):
yield DauphinEventPathMetadataEntry(		yield DauphinEventPathMetadataEntry(
label=metadata_entry.label,		label=metadata_entry.label,
description=metadata_entry.description,		description=metadata_entry.description,
path=metadata_entry.entry_data.path,		path=metadata_entry.entry_data.path,
)		)
		elif isinstance(metadata_entry.entry_data, AddressMetadataEntryData):
		yield DauphinEventAddressMetadataEntry(
		label=metadata_entry.label,
		description=metadata_entry.description,
		address=metadata_entry.entry_data.address,
		)
elif isinstance(metadata_entry.entry_data, JsonMetadataEntryData):		elif isinstance(metadata_entry.entry_data, JsonMetadataEntryData):
yield DauphinEventJsonMetadataEntry(		yield DauphinEventJsonMetadataEntry(
label=metadata_entry.label,		label=metadata_entry.label,
description=metadata_entry.description,		description=metadata_entry.description,
jsonString=seven.json.dumps(metadata_entry.entry_data.data),		jsonString=seven.json.dumps(metadata_entry.entry_data.data),
)		)
elif isinstance(metadata_entry.entry_data, TextMetadataEntryData):		elif isinstance(metadata_entry.entry_data, TextMetadataEntryData):
yield DauphinEventTextMetadataEntry(		yield DauphinEventTextMetadataEntry(
Show All 37 Lines	def _to_dauphin_metadata_entries(metadata_entries):
return list(iterate_metadata_entries(metadata_entries) or [])		return list(iterate_metadata_entries(metadata_entries) or [])


class DauphinObjectStoreOperationType(dauphin.Enum):		class DauphinObjectStoreOperationType(dauphin.Enum):
class Meta(object):		class Meta(object):
name = "ObjectStoreOperationType"		name = "ObjectStoreOperationType"

SET_OBJECT = "SET_OBJECT"		SET_OBJECT = "SET_OBJECT"
		SET_EXTERNAL_OBJECT = "SET_EXTERNAL_OBJECT"
GET_OBJECT = "GET_OBJECT"		GET_OBJECT = "GET_OBJECT"
		GET_EXTERNAL_OBJECT = "GET_EXTERNAL_OBJECT"
RM_OBJECT = "RM_OBJECT"		RM_OBJECT = "RM_OBJECT"
CP_OBJECT = "CP_OBJECT"		CP_OBJECT = "CP_OBJECT"


class DauphinObjectStoreOperationResult(dauphin.ObjectType):		class DauphinObjectStoreOperationResult(dauphin.ObjectType):
class Meta(object):		class Meta(object):
name = "ObjectStoreOperationResult"		name = "ObjectStoreOperationResult"
interfaces = (DauphinDisplayableEvent,)		interfaces = (DauphinDisplayableEvent,)
▲ Show 20 Lines • Show All 323 Lines • Show Last 20 Lines