Changeset View
Changeset View
Standalone View
Standalone View
python_modules/dagster/dagster/core/snap/dep_snapshot.py
| Show All 32 Lines | return SolidInvocationSnap( | ||||
| solid_name=solid.name, | solid_name=solid.name, | ||||
| solid_def_name=solid.definition.name, | solid_def_name=solid.definition.name, | ||||
| tags=solid.tags, | tags=solid.tags, | ||||
| input_dep_snaps=input_def_snaps, | input_dep_snaps=input_def_snaps, | ||||
| is_dynamic_mapped=dep_structure.is_dynamic_mapped(solid.name), | is_dynamic_mapped=dep_structure.is_dynamic_mapped(solid.name), | ||||
| ) | ) | ||||
| def build_dep_structure_snapshot_from_icontains_solids(icontains_solids): | def build_dep_structure_snapshot_from_graph(graph): | ||||
| check.inst_param(icontains_solids, "icontains_solids", GraphDefinition) | check.inst_param(graph, "graph", GraphDefinition) | ||||
| return DependencyStructureSnapshot( | return DependencyStructureSnapshot( | ||||
| solid_invocation_snaps=[ | solid_invocation_snaps=[build_solid_invocation_snap(graph, solid) for solid in graph.solids] | ||||
| build_solid_invocation_snap(icontains_solids, solid) | |||||
| for solid in icontains_solids.solids | |||||
| ] | |||||
| ) | ) | ||||
| @whitelist_for_serdes | @whitelist_for_serdes | ||||
| class DependencyStructureSnapshot( | class DependencyStructureSnapshot( | ||||
| namedtuple("_DependencyStructureSnapshot", "solid_invocation_snaps") | namedtuple("_DependencyStructureSnapshot", "solid_invocation_snaps") | ||||
| ): | ): | ||||
| def __new__(cls, solid_invocation_snaps): | def __new__(cls, solid_invocation_snaps): | ||||
| ▲ Show 20 Lines • Show All 149 Lines • Show Last 20 Lines | |||||