From 2050fcc9267b08bf4f75fe7cf456dae8765c7e31 Mon Sep 17 00:00:00 2001 From: prha Date: Thu, 2 Jan 2025 11:02:21 -0800 Subject: [PATCH] thread pool information to graphql layer --- .../ui-core/src/graphql/schema.graphql | 2 + .../packages/ui-core/src/graphql/types.ts | 4 + .../dagster_graphql/schema/asset_graph.py | 4 + .../dagster_graphql/schema/solids.py | 4 + .../__snapshots__/test_all_snapshot_ids.ambr | 1282 ++++++++++++----- .../graphql/__snapshots__/test_assets.ambr | 52 + .../dagster_graphql_tests/graphql/repo.py | 35 + .../graphql/test_assets.py | 25 + 8 files changed, 1017 insertions(+), 391 deletions(-) diff --git a/js_modules/dagster-ui/packages/ui-core/src/graphql/schema.graphql b/js_modules/dagster-ui/packages/ui-core/src/graphql/schema.graphql index 11e6447c87c64..aa4b81ed6b08f 100644 --- a/js_modules/dagster-ui/packages/ui-core/src/graphql/schema.graphql +++ b/js_modules/dagster-ui/packages/ui-core/src/graphql/schema.graphql @@ -634,6 +634,7 @@ type AssetNode { backfillPolicy: BackfillPolicy changedReasons: [ChangeReason!]! computeKind: String + pools: [String!]! configField: ConfigTypeField dataVersion(partition: String): String dataVersionByPartition(partitions: [String!]): [String]! @@ -3186,6 +3187,7 @@ type SolidDefinition implements ISolidDefinition { assetNodes: [AssetNode!]! configField: ConfigTypeField requiredResources: [ResourceRequirement!]! + pool: String } type SolidHandle { diff --git a/js_modules/dagster-ui/packages/ui-core/src/graphql/types.ts b/js_modules/dagster-ui/packages/ui-core/src/graphql/types.ts index b351ec513ad28..fb9ee0b434f8e 100644 --- a/js_modules/dagster-ui/packages/ui-core/src/graphql/types.ts +++ b/js_modules/dagster-ui/packages/ui-core/src/graphql/types.ts @@ -483,6 +483,7 @@ export type AssetNode = { partitionKeys: Array; partitionKeysByDimension: Array; partitionStats: Maybe; + pools: Array; repository: Repository; requiredResources: Array; staleCauses: Array; @@ -5187,6 +5188,7 @@ export type SolidDefinition = ISolidDefinition & { metadata: Array; name: Scalars['String']['output']; outputDefinitions: Array; + pool: Maybe; requiredResources: Array; }; @@ -6718,6 +6720,7 @@ export const buildAssetNode = ( : relationshipsToOmit.has('PartitionStats') ? ({} as PartitionStats) : buildPartitionStats({}, relationshipsToOmit), + pools: overrides && overrides.hasOwnProperty('pools') ? overrides.pools! : [], repository: overrides && overrides.hasOwnProperty('repository') ? overrides.repository! @@ -14451,6 +14454,7 @@ export const buildSolidDefinition = ( overrides && overrides.hasOwnProperty('outputDefinitions') ? overrides.outputDefinitions! : [], + pool: overrides && overrides.hasOwnProperty('pool') ? overrides.pool! : 'voluptates', requiredResources: overrides && overrides.hasOwnProperty('requiredResources') ? overrides.requiredResources! diff --git a/python_modules/dagster-graphql/dagster_graphql/schema/asset_graph.py b/python_modules/dagster-graphql/dagster_graphql/schema/asset_graph.py index 6473b7e1bbed3..68cc17bb0b58a 100644 --- a/python_modules/dagster-graphql/dagster_graphql/schema/asset_graph.py +++ b/python_modules/dagster-graphql/dagster_graphql/schema/asset_graph.py @@ -240,6 +240,7 @@ class GrapheneAssetNode(graphene.ObjectType): backfillPolicy = graphene.Field(GrapheneBackfillPolicy) changedReasons = graphene.Field(non_null_list(GrapheneAssetChangedReason)) computeKind = graphene.String() + pools = non_null_list(graphene.String) configField = graphene.Field(GrapheneConfigTypeField) dataVersion = graphene.Field(graphene.String(), partition=graphene.String()) dataVersionByPartition = graphene.Field( @@ -671,6 +672,9 @@ def _get_config_type(key: str): field_snap=node_def_snap.config_field_snap, ) + def resolve_pools(self, _graphene_info: ResolveInfo) -> Sequence[str]: + return sorted([pool for pool in self._asset_node_snap.pools or set()]) + def resolve_computeKind(self, _graphene_info: ResolveInfo) -> Optional[str]: return self._asset_node_snap.compute_kind diff --git a/python_modules/dagster-graphql/dagster_graphql/schema/solids.py b/python_modules/dagster-graphql/dagster_graphql/schema/solids.py index 0a1a58b15133a..0412cbd0d40ed 100644 --- a/python_modules/dagster-graphql/dagster_graphql/schema/solids.py +++ b/python_modules/dagster-graphql/dagster_graphql/schema/solids.py @@ -468,6 +468,7 @@ def resolve_assetNodes(self, graphene_info: ResolveInfo) -> Sequence["GrapheneAs class GrapheneSolidDefinition(graphene.ObjectType, ISolidDefinitionMixin): config_field = graphene.Field(GrapheneConfigTypeField) required_resources = non_null_list(GrapheneResourceRequirement) + pool = graphene.String() class Meta: interfaces = (GrapheneISolidDefinition,) @@ -501,6 +502,9 @@ def resolve_required_resources( GrapheneResourceRequirement(key) for key in self._solid_def_snap.required_resource_keys ] + def resolve_pool(self, _graphene_info: ResolveInfo) -> Optional[str]: + return self._solid_def_snap.pool + class GrapheneSolidStepStatsUnavailableError(graphene.ObjectType): class Meta: diff --git a/python_modules/dagster-graphql/dagster_graphql_tests/graphql/__snapshots__/test_all_snapshot_ids.ambr b/python_modules/dagster-graphql/dagster_graphql_tests/graphql/__snapshots__/test_all_snapshot_ids.ambr index 260759614f90a..a7a0045c55714 100644 --- a/python_modules/dagster-graphql/dagster_graphql_tests/graphql/__snapshots__/test_all_snapshot_ids.ambr +++ b/python_modules/dagster-graphql/dagster_graphql_tests/graphql/__snapshots__/test_all_snapshot_ids.ambr @@ -489,7 +489,364 @@ "scalar_kind": null, "type_param_keys": null }, - "Shape.2923e2efed8c6ae4999833e86ce030061009998f": { + "Shape.2db9cd385a1c02ba97b38cd51002d65fef8593f2": { + "__class__": "ConfigTypeSnap", + "description": null, + "enum_values": null, + "fields": [ + { + "__class__": "ConfigFieldSnap", + "default_provided": true, + "default_value_as_json_str": "{\"config\": {\"retries\": {\"enabled\": {}}}}", + "description": "Configure how steps are executed within a run.", + "is_required": false, + "name": "execution", + "type_key": "Shape.09d73f0755bf4752d3f121837669c8660dcf451e" + }, + { + "__class__": "ConfigFieldSnap", + "default_provided": true, + "default_value_as_json_str": "{}", + "description": "Configure how loggers emit messages within a run.", + "is_required": false, + "name": "loggers", + "type_key": "Shape.e895d95ee6d0eff1b884c76f44a2ab7089f0c49b" + }, + { + "__class__": "ConfigFieldSnap", + "default_provided": true, + "default_value_as_json_str": "{\"asset_1\": {}, \"asset_1_my_check\": {}, \"asset_2\": {}, \"asset_3\": {}, \"asset_one\": {}, \"asset_two\": {}, \"asset_with_automation_condition\": {}, \"asset_with_compute_storage_kinds\": {\"config\": {}}, \"asset_with_custom_automation_condition\": {}, \"asset_yields_observation\": {}, \"bar\": {}, \"baz\": {}, \"check_in_op_asset\": {}, \"concurrency_asset\": {}, \"concurrency_graph_asset\": {\"ops\": {\"concurrency_op_1\": {}, \"concurrency_op_2\": {}}}, \"concurrency_multi_asset\": {\"config\": {}}, \"downstream_asset\": {}, \"downstream_dynamic_partitioned_asset\": {}, \"downstream_static_partitioned_asset\": {}, \"downstream_time_partitioned_asset\": {}, \"downstream_weekly_partitioned_asset\": {}, \"dynamic_in_multipartitions_fail\": {}, \"dynamic_in_multipartitions_success\": {}, \"executable_asset\": {}, \"fail_partition_materialization\": {}, \"first_asset\": {}, \"foo\": {}, \"foo_bar\": {}, \"fresh_diamond_bottom\": {}, \"fresh_diamond_left\": {}, \"fresh_diamond_right\": {}, \"fresh_diamond_top\": {}, \"grouped_asset_1\": {}, \"grouped_asset_2\": {}, \"grouped_asset_4\": {}, \"hanging_asset\": {}, \"hanging_graph\": {\"ops\": {\"hanging_op\": {}, \"my_op\": {}, \"never_runs_op\": {}}}, \"hanging_partition_asset\": {}, \"integers_asset\": {}, \"middle_static_partitioned_asset_1\": {}, \"middle_static_partitioned_asset_2\": {}, \"multi_asset_with_kinds\": {\"config\": {}}, \"multi_run_backfill_policy_asset\": {}, \"multipartitions_1\": {}, \"multipartitions_2\": {}, \"multipartitions_fail\": {}, \"never_runs_asset\": {}, \"no_multipartitions_1\": {}, \"not_included_asset\": {}, \"output_then_hang_asset\": {}, \"single_run_backfill_policy_asset\": {}, \"subsettable_checked_multi_asset\": {\"config\": {}}, \"typed_asset\": {}, \"typed_multi_asset\": {\"config\": {}}, \"unconnected\": {}, \"ungrouped_asset_3\": {}, \"ungrouped_asset_5\": {}, \"unpartitioned_upstream_of_partitioned\": {}, \"untyped_asset\": {}, \"upstream_daily_partitioned_asset\": {}, \"upstream_dynamic_partitioned_asset\": {}, \"upstream_static_partitioned_asset\": {}, \"upstream_time_partitioned_asset\": {}, \"yield_partition_materialization\": {}}", + "description": "Configure runtime parameters for ops or assets.", + "is_required": false, + "name": "ops", + "type_key": "Shape.c71ef76e3de43bf6c3f361fbe08a4075e718a568" + }, + { + "__class__": "ConfigFieldSnap", + "default_provided": false, + "default_value_as_json_str": null, + "description": "Configure how shared resources are implemented within a run.", + "is_required": true, + "name": "resources", + "type_key": "Shape.7493b137e48f8d4b013bce61e92617ff1bc51f7f" + } + ], + "given_name": null, + "key": "Shape.2db9cd385a1c02ba97b38cd51002d65fef8593f2", + "kind": { + "__enum__": "ConfigTypeKind.STRICT_SHAPE" + }, + "scalar_kind": null, + "type_param_keys": null + }, + "Shape.31ebade63b77a8095e9f78414e75445567b90463": { + "__class__": "ConfigTypeSnap", + "description": null, + "enum_values": null, + "fields": [ + { + "__class__": "ConfigFieldSnap", + "default_provided": true, + "default_value_as_json_str": "{}", + "description": null, + "is_required": false, + "name": "concurrency_op_1", + "type_key": "Shape.743e47901855cb245064dd633e217bfcb49a11a7" + }, + { + "__class__": "ConfigFieldSnap", + "default_provided": true, + "default_value_as_json_str": "{}", + "description": null, + "is_required": false, + "name": "concurrency_op_2", + "type_key": "Shape.743e47901855cb245064dd633e217bfcb49a11a7" + } + ], + "given_name": null, + "key": "Shape.31ebade63b77a8095e9f78414e75445567b90463", + "kind": { + "__enum__": "ConfigTypeKind.STRICT_SHAPE" + }, + "scalar_kind": null, + "type_param_keys": null + }, + "Shape.35d3e42b53e66506c5867f04644849cd03763bc6": { + "__class__": "ConfigTypeSnap", + "description": null, + "enum_values": null, + "fields": [ + { + "__class__": "ConfigFieldSnap", + "default_provided": true, + "default_value_as_json_str": "{\"hanging_op\": {}, \"my_op\": {}, \"never_runs_op\": {}}", + "description": null, + "is_required": false, + "name": "ops", + "type_key": "Shape.811a60b4c43530c3d6100304f377dbd2d3045291" + } + ], + "given_name": null, + "key": "Shape.35d3e42b53e66506c5867f04644849cd03763bc6", + "kind": { + "__enum__": "ConfigTypeKind.STRICT_SHAPE" + }, + "scalar_kind": null, + "type_param_keys": null + }, + "Shape.44f24ac55059da1634e84af6c1bf7e0ed332251c": { + "__class__": "ConfigTypeSnap", + "description": null, + "enum_values": null, + "fields": [ + { + "__class__": "ConfigFieldSnap", + "default_provided": false, + "default_value_as_json_str": null, + "description": "[DEPRECATED]", + "is_required": false, + "name": "marker_to_close", + "type_key": "String" + }, + { + "__class__": "ConfigFieldSnap", + "default_provided": true, + "default_value_as_json_str": "{\"enabled\": {}}", + "description": "Whether retries are enabled or not. By default, retries are enabled.", + "is_required": false, + "name": "retries", + "type_key": "Selector.1bfb167aea90780aa679597800c71bd8c65ed0b2" + } + ], + "given_name": null, + "key": "Shape.44f24ac55059da1634e84af6c1bf7e0ed332251c", + "kind": { + "__enum__": "ConfigTypeKind.STRICT_SHAPE" + }, + "scalar_kind": null, + "type_param_keys": null + }, + "Shape.44f2a71367507edd1b8e64f739222c4312b3691b": { + "__class__": "ConfigTypeSnap", + "description": null, + "enum_values": null, + "fields": [ + { + "__class__": "ConfigFieldSnap", + "default_provided": true, + "default_value_as_json_str": "{}", + "description": null, + "is_required": false, + "name": "config", + "type_key": "Shape.18b2faaf1efd505374f7f25fcb61ed59bd5be851" + } + ], + "given_name": null, + "key": "Shape.44f2a71367507edd1b8e64f739222c4312b3691b", + "kind": { + "__enum__": "ConfigTypeKind.STRICT_SHAPE" + }, + "scalar_kind": null, + "type_param_keys": null + }, + "Shape.4b53b73df342381d0d05c5f36183dc99cb9676e2": { + "__class__": "ConfigTypeSnap", + "description": null, + "enum_values": null, + "fields": [ + { + "__class__": "ConfigFieldSnap", + "default_provided": false, + "default_value_as_json_str": null, + "description": null, + "is_required": true, + "name": "path", + "type_key": "String" + } + ], + "given_name": null, + "key": "Shape.4b53b73df342381d0d05c5f36183dc99cb9676e2", + "kind": { + "__enum__": "ConfigTypeKind.STRICT_SHAPE" + }, + "scalar_kind": null, + "type_param_keys": null + }, + "Shape.62edccaf30696e25335ae92685bdc41e204e30e6": { + "__class__": "ConfigTypeSnap", + "description": null, + "enum_values": null, + "fields": [ + { + "__class__": "ConfigFieldSnap", + "default_provided": true, + "default_value_as_json_str": "{}", + "description": null, + "is_required": false, + "name": "config", + "type_key": "Shape.da39a3ee5e6b4b0d3255bfef95601890afd80709" + } + ], + "given_name": null, + "key": "Shape.62edccaf30696e25335ae92685bdc41e204e30e6", + "kind": { + "__enum__": "ConfigTypeKind.STRICT_SHAPE" + }, + "scalar_kind": null, + "type_param_keys": null + }, + "Shape.743e47901855cb245064dd633e217bfcb49a11a7": { + "__class__": "ConfigTypeSnap", + "description": null, + "enum_values": null, + "fields": [ + { + "__class__": "ConfigFieldSnap", + "default_provided": false, + "default_value_as_json_str": null, + "description": null, + "is_required": false, + "name": "config", + "type_key": "Any" + } + ], + "given_name": null, + "key": "Shape.743e47901855cb245064dd633e217bfcb49a11a7", + "kind": { + "__enum__": "ConfigTypeKind.STRICT_SHAPE" + }, + "scalar_kind": null, + "type_param_keys": null + }, + "Shape.7493b137e48f8d4b013bce61e92617ff1bc51f7f": { + "__class__": "ConfigTypeSnap", + "description": null, + "enum_values": null, + "fields": [ + { + "__class__": "ConfigFieldSnap", + "default_provided": true, + "default_value_as_json_str": "{}", + "description": null, + "is_required": false, + "name": "dummy_io_manager", + "type_key": "Shape.743e47901855cb245064dd633e217bfcb49a11a7" + }, + { + "__class__": "ConfigFieldSnap", + "default_provided": false, + "default_value_as_json_str": null, + "description": null, + "is_required": true, + "name": "hanging_asset_resource", + "type_key": "Shape.b13a6c5637084590cc1538f9522324bfeb4b46b3" + }, + { + "__class__": "ConfigFieldSnap", + "default_provided": true, + "default_value_as_json_str": "{\"config\": {}}", + "description": "Built-in filesystem IO manager that stores and retrieves values using pickling.", + "is_required": false, + "name": "io_manager", + "type_key": "Shape.44f2a71367507edd1b8e64f739222c4312b3691b" + } + ], + "given_name": null, + "key": "Shape.7493b137e48f8d4b013bce61e92617ff1bc51f7f", + "kind": { + "__enum__": "ConfigTypeKind.STRICT_SHAPE" + }, + "scalar_kind": null, + "type_param_keys": null + }, + "Shape.811a60b4c43530c3d6100304f377dbd2d3045291": { + "__class__": "ConfigTypeSnap", + "description": null, + "enum_values": null, + "fields": [ + { + "__class__": "ConfigFieldSnap", + "default_provided": true, + "default_value_as_json_str": "{}", + "description": null, + "is_required": false, + "name": "hanging_op", + "type_key": "Shape.743e47901855cb245064dd633e217bfcb49a11a7" + }, + { + "__class__": "ConfigFieldSnap", + "default_provided": true, + "default_value_as_json_str": "{}", + "description": null, + "is_required": false, + "name": "my_op", + "type_key": "Shape.743e47901855cb245064dd633e217bfcb49a11a7" + }, + { + "__class__": "ConfigFieldSnap", + "default_provided": true, + "default_value_as_json_str": "{}", + "description": null, + "is_required": false, + "name": "never_runs_op", + "type_key": "Shape.743e47901855cb245064dd633e217bfcb49a11a7" + } + ], + "given_name": null, + "key": "Shape.811a60b4c43530c3d6100304f377dbd2d3045291", + "kind": { + "__enum__": "ConfigTypeKind.STRICT_SHAPE" + }, + "scalar_kind": null, + "type_param_keys": null + }, + "Shape.9a3a315bff2146cca750edbec49c6b4b4d0ce58e": { + "__class__": "ConfigTypeSnap", + "description": null, + "enum_values": null, + "fields": [ + { + "__class__": "ConfigFieldSnap", + "default_provided": false, + "default_value_as_json_str": null, + "description": null, + "is_required": true, + "name": "file", + "type_key": "String" + } + ], + "given_name": null, + "key": "Shape.9a3a315bff2146cca750edbec49c6b4b4d0ce58e", + "kind": { + "__enum__": "ConfigTypeKind.STRICT_SHAPE" + }, + "scalar_kind": null, + "type_param_keys": null + }, + "Shape.b13a6c5637084590cc1538f9522324bfeb4b46b3": { + "__class__": "ConfigTypeSnap", + "description": null, + "enum_values": null, + "fields": [ + { + "__class__": "ConfigFieldSnap", + "default_provided": false, + "default_value_as_json_str": null, + "description": null, + "is_required": true, + "name": "config", + "type_key": "Shape.9a3a315bff2146cca750edbec49c6b4b4d0ce58e" + } + ], + "given_name": null, + "key": "Shape.b13a6c5637084590cc1538f9522324bfeb4b46b3", + "kind": { + "__enum__": "ConfigTypeKind.STRICT_SHAPE" + }, + "scalar_kind": null, + "type_param_keys": null + }, + "Shape.c71ef76e3de43bf6c3f361fbe08a4075e718a568": { "__class__": "ConfigTypeSnap", "description": null, "enum_values": null, @@ -611,6 +968,33 @@ "name": "check_in_op_asset", "type_key": "Shape.743e47901855cb245064dd633e217bfcb49a11a7" }, + { + "__class__": "ConfigFieldSnap", + "default_provided": true, + "default_value_as_json_str": "{}", + "description": null, + "is_required": false, + "name": "concurrency_asset", + "type_key": "Shape.743e47901855cb245064dd633e217bfcb49a11a7" + }, + { + "__class__": "ConfigFieldSnap", + "default_provided": true, + "default_value_as_json_str": "{\"ops\": {\"concurrency_op_1\": {}, \"concurrency_op_2\": {}}}", + "description": null, + "is_required": false, + "name": "concurrency_graph_asset", + "type_key": "Shape.fd8c16292fa02a225e66a5c404ad8b4f5b0924e5" + }, + { + "__class__": "ConfigFieldSnap", + "default_provided": true, + "default_value_as_json_str": "{\"config\": {}}", + "description": null, + "is_required": false, + "name": "concurrency_multi_asset", + "type_key": "Shape.62edccaf30696e25335ae92685bdc41e204e30e6" + }, { "__class__": "ConfigFieldSnap", "default_provided": true, @@ -1045,37 +1429,27 @@ } ], "given_name": null, - "key": "Shape.2923e2efed8c6ae4999833e86ce030061009998f", + "key": "Shape.c71ef76e3de43bf6c3f361fbe08a4075e718a568", "kind": { "__enum__": "ConfigTypeKind.STRICT_SHAPE" }, "scalar_kind": null, "type_param_keys": null }, - "Shape.35d3e42b53e66506c5867f04644849cd03763bc6": { + "Shape.da39a3ee5e6b4b0d3255bfef95601890afd80709": { "__class__": "ConfigTypeSnap", "description": null, "enum_values": null, - "fields": [ - { - "__class__": "ConfigFieldSnap", - "default_provided": true, - "default_value_as_json_str": "{\"hanging_op\": {}, \"my_op\": {}, \"never_runs_op\": {}}", - "description": null, - "is_required": false, - "name": "ops", - "type_key": "Shape.811a60b4c43530c3d6100304f377dbd2d3045291" - } - ], + "fields": [], "given_name": null, - "key": "Shape.35d3e42b53e66506c5867f04644849cd03763bc6", + "key": "Shape.da39a3ee5e6b4b0d3255bfef95601890afd80709", "kind": { "__enum__": "ConfigTypeKind.STRICT_SHAPE" }, "scalar_kind": null, "type_param_keys": null }, - "Shape.44f24ac55059da1634e84af6c1bf7e0ed332251c": { + "Shape.e895d95ee6d0eff1b884c76f44a2ab7089f0c49b": { "__class__": "ConfigTypeSnap", "description": null, "enum_values": null, @@ -1084,76 +1458,21 @@ "__class__": "ConfigFieldSnap", "default_provided": false, "default_value_as_json_str": null, - "description": "[DEPRECATED]", - "is_required": false, - "name": "marker_to_close", - "type_key": "String" - }, - { - "__class__": "ConfigFieldSnap", - "default_provided": true, - "default_value_as_json_str": "{\"enabled\": {}}", - "description": "Whether retries are enabled or not. By default, retries are enabled.", - "is_required": false, - "name": "retries", - "type_key": "Selector.1bfb167aea90780aa679597800c71bd8c65ed0b2" - } - ], - "given_name": null, - "key": "Shape.44f24ac55059da1634e84af6c1bf7e0ed332251c", - "kind": { - "__enum__": "ConfigTypeKind.STRICT_SHAPE" - }, - "scalar_kind": null, - "type_param_keys": null - }, - "Shape.44f2a71367507edd1b8e64f739222c4312b3691b": { - "__class__": "ConfigTypeSnap", - "description": null, - "enum_values": null, - "fields": [ - { - "__class__": "ConfigFieldSnap", - "default_provided": true, - "default_value_as_json_str": "{}", "description": null, "is_required": false, - "name": "config", - "type_key": "Shape.18b2faaf1efd505374f7f25fcb61ed59bd5be851" - } - ], - "given_name": null, - "key": "Shape.44f2a71367507edd1b8e64f739222c4312b3691b", - "kind": { - "__enum__": "ConfigTypeKind.STRICT_SHAPE" - }, - "scalar_kind": null, - "type_param_keys": null - }, - "Shape.4b53b73df342381d0d05c5f36183dc99cb9676e2": { - "__class__": "ConfigTypeSnap", - "description": null, - "enum_values": null, - "fields": [ - { - "__class__": "ConfigFieldSnap", - "default_provided": false, - "default_value_as_json_str": null, - "description": null, - "is_required": true, - "name": "path", - "type_key": "String" + "name": "console", + "type_key": "Shape.0fe8353d6b542accfad9becbdbaeb92f649ebb9a" } ], "given_name": null, - "key": "Shape.4b53b73df342381d0d05c5f36183dc99cb9676e2", + "key": "Shape.e895d95ee6d0eff1b884c76f44a2ab7089f0c49b", "kind": { "__enum__": "ConfigTypeKind.STRICT_SHAPE" }, "scalar_kind": null, "type_param_keys": null }, - "Shape.62edccaf30696e25335ae92685bdc41e204e30e6": { + "Shape.fd8c16292fa02a225e66a5c404ad8b4f5b0924e5": { "__class__": "ConfigTypeSnap", "description": null, "enum_values": null, @@ -1161,252 +1480,15 @@ { "__class__": "ConfigFieldSnap", "default_provided": true, - "default_value_as_json_str": "{}", + "default_value_as_json_str": "{\"concurrency_op_1\": {}, \"concurrency_op_2\": {}}", "description": null, "is_required": false, - "name": "config", - "type_key": "Shape.da39a3ee5e6b4b0d3255bfef95601890afd80709" - } - ], - "given_name": null, - "key": "Shape.62edccaf30696e25335ae92685bdc41e204e30e6", - "kind": { - "__enum__": "ConfigTypeKind.STRICT_SHAPE" - }, - "scalar_kind": null, - "type_param_keys": null - }, - "Shape.6c71186a8f3069ee444291a42734fb8144db65fe": { - "__class__": "ConfigTypeSnap", - "description": null, - "enum_values": null, - "fields": [ - { - "__class__": "ConfigFieldSnap", - "default_provided": true, - "default_value_as_json_str": "{\"config\": {\"retries\": {\"enabled\": {}}}}", - "description": "Configure how steps are executed within a run.", - "is_required": false, - "name": "execution", - "type_key": "Shape.09d73f0755bf4752d3f121837669c8660dcf451e" - }, - { - "__class__": "ConfigFieldSnap", - "default_provided": true, - "default_value_as_json_str": "{}", - "description": "Configure how loggers emit messages within a run.", - "is_required": false, - "name": "loggers", - "type_key": "Shape.e895d95ee6d0eff1b884c76f44a2ab7089f0c49b" - }, - { - "__class__": "ConfigFieldSnap", - "default_provided": true, - "default_value_as_json_str": "{\"asset_1\": {}, \"asset_1_my_check\": {}, \"asset_2\": {}, \"asset_3\": {}, \"asset_one\": {}, \"asset_two\": {}, \"asset_with_automation_condition\": {}, \"asset_with_compute_storage_kinds\": {\"config\": {}}, \"asset_with_custom_automation_condition\": {}, \"asset_yields_observation\": {}, \"bar\": {}, \"baz\": {}, \"check_in_op_asset\": {}, \"downstream_asset\": {}, \"downstream_dynamic_partitioned_asset\": {}, \"downstream_static_partitioned_asset\": {}, \"downstream_time_partitioned_asset\": {}, \"downstream_weekly_partitioned_asset\": {}, \"dynamic_in_multipartitions_fail\": {}, \"dynamic_in_multipartitions_success\": {}, \"executable_asset\": {}, \"fail_partition_materialization\": {}, \"first_asset\": {}, \"foo\": {}, \"foo_bar\": {}, \"fresh_diamond_bottom\": {}, \"fresh_diamond_left\": {}, \"fresh_diamond_right\": {}, \"fresh_diamond_top\": {}, \"grouped_asset_1\": {}, \"grouped_asset_2\": {}, \"grouped_asset_4\": {}, \"hanging_asset\": {}, \"hanging_graph\": {\"ops\": {\"hanging_op\": {}, \"my_op\": {}, \"never_runs_op\": {}}}, \"hanging_partition_asset\": {}, \"integers_asset\": {}, \"middle_static_partitioned_asset_1\": {}, \"middle_static_partitioned_asset_2\": {}, \"multi_asset_with_kinds\": {\"config\": {}}, \"multi_run_backfill_policy_asset\": {}, \"multipartitions_1\": {}, \"multipartitions_2\": {}, \"multipartitions_fail\": {}, \"never_runs_asset\": {}, \"no_multipartitions_1\": {}, \"not_included_asset\": {}, \"output_then_hang_asset\": {}, \"single_run_backfill_policy_asset\": {}, \"subsettable_checked_multi_asset\": {\"config\": {}}, \"typed_asset\": {}, \"typed_multi_asset\": {\"config\": {}}, \"unconnected\": {}, \"ungrouped_asset_3\": {}, \"ungrouped_asset_5\": {}, \"unpartitioned_upstream_of_partitioned\": {}, \"untyped_asset\": {}, \"upstream_daily_partitioned_asset\": {}, \"upstream_dynamic_partitioned_asset\": {}, \"upstream_static_partitioned_asset\": {}, \"upstream_time_partitioned_asset\": {}, \"yield_partition_materialization\": {}}", - "description": "Configure runtime parameters for ops or assets.", - "is_required": false, "name": "ops", - "type_key": "Shape.2923e2efed8c6ae4999833e86ce030061009998f" - }, - { - "__class__": "ConfigFieldSnap", - "default_provided": false, - "default_value_as_json_str": null, - "description": "Configure how shared resources are implemented within a run.", - "is_required": true, - "name": "resources", - "type_key": "Shape.7493b137e48f8d4b013bce61e92617ff1bc51f7f" + "type_key": "Shape.31ebade63b77a8095e9f78414e75445567b90463" } ], "given_name": null, - "key": "Shape.6c71186a8f3069ee444291a42734fb8144db65fe", - "kind": { - "__enum__": "ConfigTypeKind.STRICT_SHAPE" - }, - "scalar_kind": null, - "type_param_keys": null - }, - "Shape.743e47901855cb245064dd633e217bfcb49a11a7": { - "__class__": "ConfigTypeSnap", - "description": null, - "enum_values": null, - "fields": [ - { - "__class__": "ConfigFieldSnap", - "default_provided": false, - "default_value_as_json_str": null, - "description": null, - "is_required": false, - "name": "config", - "type_key": "Any" - } - ], - "given_name": null, - "key": "Shape.743e47901855cb245064dd633e217bfcb49a11a7", - "kind": { - "__enum__": "ConfigTypeKind.STRICT_SHAPE" - }, - "scalar_kind": null, - "type_param_keys": null - }, - "Shape.7493b137e48f8d4b013bce61e92617ff1bc51f7f": { - "__class__": "ConfigTypeSnap", - "description": null, - "enum_values": null, - "fields": [ - { - "__class__": "ConfigFieldSnap", - "default_provided": true, - "default_value_as_json_str": "{}", - "description": null, - "is_required": false, - "name": "dummy_io_manager", - "type_key": "Shape.743e47901855cb245064dd633e217bfcb49a11a7" - }, - { - "__class__": "ConfigFieldSnap", - "default_provided": false, - "default_value_as_json_str": null, - "description": null, - "is_required": true, - "name": "hanging_asset_resource", - "type_key": "Shape.b13a6c5637084590cc1538f9522324bfeb4b46b3" - }, - { - "__class__": "ConfigFieldSnap", - "default_provided": true, - "default_value_as_json_str": "{\"config\": {}}", - "description": "Built-in filesystem IO manager that stores and retrieves values using pickling.", - "is_required": false, - "name": "io_manager", - "type_key": "Shape.44f2a71367507edd1b8e64f739222c4312b3691b" - } - ], - "given_name": null, - "key": "Shape.7493b137e48f8d4b013bce61e92617ff1bc51f7f", - "kind": { - "__enum__": "ConfigTypeKind.STRICT_SHAPE" - }, - "scalar_kind": null, - "type_param_keys": null - }, - "Shape.811a60b4c43530c3d6100304f377dbd2d3045291": { - "__class__": "ConfigTypeSnap", - "description": null, - "enum_values": null, - "fields": [ - { - "__class__": "ConfigFieldSnap", - "default_provided": true, - "default_value_as_json_str": "{}", - "description": null, - "is_required": false, - "name": "hanging_op", - "type_key": "Shape.743e47901855cb245064dd633e217bfcb49a11a7" - }, - { - "__class__": "ConfigFieldSnap", - "default_provided": true, - "default_value_as_json_str": "{}", - "description": null, - "is_required": false, - "name": "my_op", - "type_key": "Shape.743e47901855cb245064dd633e217bfcb49a11a7" - }, - { - "__class__": "ConfigFieldSnap", - "default_provided": true, - "default_value_as_json_str": "{}", - "description": null, - "is_required": false, - "name": "never_runs_op", - "type_key": "Shape.743e47901855cb245064dd633e217bfcb49a11a7" - } - ], - "given_name": null, - "key": "Shape.811a60b4c43530c3d6100304f377dbd2d3045291", - "kind": { - "__enum__": "ConfigTypeKind.STRICT_SHAPE" - }, - "scalar_kind": null, - "type_param_keys": null - }, - "Shape.9a3a315bff2146cca750edbec49c6b4b4d0ce58e": { - "__class__": "ConfigTypeSnap", - "description": null, - "enum_values": null, - "fields": [ - { - "__class__": "ConfigFieldSnap", - "default_provided": false, - "default_value_as_json_str": null, - "description": null, - "is_required": true, - "name": "file", - "type_key": "String" - } - ], - "given_name": null, - "key": "Shape.9a3a315bff2146cca750edbec49c6b4b4d0ce58e", - "kind": { - "__enum__": "ConfigTypeKind.STRICT_SHAPE" - }, - "scalar_kind": null, - "type_param_keys": null - }, - "Shape.b13a6c5637084590cc1538f9522324bfeb4b46b3": { - "__class__": "ConfigTypeSnap", - "description": null, - "enum_values": null, - "fields": [ - { - "__class__": "ConfigFieldSnap", - "default_provided": false, - "default_value_as_json_str": null, - "description": null, - "is_required": true, - "name": "config", - "type_key": "Shape.9a3a315bff2146cca750edbec49c6b4b4d0ce58e" - } - ], - "given_name": null, - "key": "Shape.b13a6c5637084590cc1538f9522324bfeb4b46b3", - "kind": { - "__enum__": "ConfigTypeKind.STRICT_SHAPE" - }, - "scalar_kind": null, - "type_param_keys": null - }, - "Shape.da39a3ee5e6b4b0d3255bfef95601890afd80709": { - "__class__": "ConfigTypeSnap", - "description": null, - "enum_values": null, - "fields": [], - "given_name": null, - "key": "Shape.da39a3ee5e6b4b0d3255bfef95601890afd80709", - "kind": { - "__enum__": "ConfigTypeKind.STRICT_SHAPE" - }, - "scalar_kind": null, - "type_param_keys": null - }, - "Shape.e895d95ee6d0eff1b884c76f44a2ab7089f0c49b": { - "__class__": "ConfigTypeSnap", - "description": null, - "enum_values": null, - "fields": [ - { - "__class__": "ConfigFieldSnap", - "default_provided": false, - "default_value_as_json_str": null, - "description": null, - "is_required": false, - "name": "console", - "type_key": "Shape.0fe8353d6b542accfad9becbdbaeb92f649ebb9a" - } - ], - "given_name": null, - "key": "Shape.e895d95ee6d0eff1b884c76f44a2ab7089f0c49b", + "key": "Shape.fd8c16292fa02a225e66a5c404ad8b4f5b0924e5", "kind": { "__enum__": "ConfigTypeKind.STRICT_SHAPE" }, @@ -1726,6 +1808,30 @@ "solid_name": "check_in_op_asset", "tags": {} }, + { + "__class__": "SolidInvocationSnap", + "input_dep_snaps": [], + "is_dynamic_mapped": false, + "solid_def_name": "concurrency_asset", + "solid_name": "concurrency_asset", + "tags": {} + }, + { + "__class__": "SolidInvocationSnap", + "input_dep_snaps": [], + "is_dynamic_mapped": false, + "solid_def_name": "concurrency_graph_asset", + "solid_name": "concurrency_graph_asset", + "tags": {} + }, + { + "__class__": "SolidInvocationSnap", + "input_dep_snaps": [], + "is_dynamic_mapped": false, + "solid_def_name": "concurrency_multi_asset", + "solid_name": "concurrency_multi_asset", + "tags": {} + }, { "__class__": "SolidInvocationSnap", "input_dep_snaps": [ @@ -2484,13 +2590,74 @@ "name": "io_manager" } ], - "root_config_key": "Shape.6c71186a8f3069ee444291a42734fb8144db65fe" + "root_config_key": "Shape.2db9cd385a1c02ba97b38cd51002d65fef8593f2" } ], "name": "__ASSET_JOB", "solid_definitions_snapshot": { "__class__": "SolidDefinitionsSnapshot", "composite_solid_def_snaps": [ + { + "__class__": "CompositeSolidDefSnap", + "config_field_snap": null, + "dep_structure_snapshot": { + "__class__": "DependencyStructureSnapshot", + "solid_invocation_snaps": [ + { + "__class__": "SolidInvocationSnap", + "input_dep_snaps": [], + "is_dynamic_mapped": false, + "solid_def_name": "concurrency_op_1", + "solid_name": "concurrency_op_1", + "tags": {} + }, + { + "__class__": "SolidInvocationSnap", + "input_dep_snaps": [ + { + "__class__": "InputDependencySnap", + "input_name": "input_1", + "is_dynamic_collect": false, + "upstream_output_snaps": [ + { + "__class__": "OutputHandleSnap", + "output_name": "result", + "solid_name": "concurrency_op_1" + } + ] + } + ], + "is_dynamic_mapped": false, + "solid_def_name": "concurrency_op_2", + "solid_name": "concurrency_op_2", + "tags": {} + } + ] + }, + "description": null, + "input_def_snaps": [], + "input_mapping_snaps": [], + "name": "concurrency_graph_asset", + "output_def_snaps": [ + { + "__class__": "OutputDefSnap", + "dagster_type_key": "Any", + "description": null, + "is_dynamic": false, + "is_required": true, + "name": "result" + } + ], + "output_mapping_snaps": [ + { + "__class__": "OutputMappingSnap", + "external_output_name": "result", + "mapped_output_name": "result", + "mapped_solid_name": "concurrency_op_2" + } + ], + "tags": {} + }, { "__class__": "CompositeSolidDefSnap", "config_field_snap": null, @@ -2599,6 +2766,7 @@ "name": "result" } ], + "pool": null, "required_resource_keys": [], "tags": {} }, @@ -2639,6 +2807,7 @@ "name": "result" } ], + "pool": null, "required_resource_keys": [], "tags": {} }, @@ -2673,6 +2842,7 @@ "name": "result" } ], + "pool": null, "required_resource_keys": [], "tags": {} }, @@ -2707,6 +2877,7 @@ "name": "result" } ], + "pool": null, "required_resource_keys": [], "tags": {} }, @@ -2734,6 +2905,7 @@ "name": "result" } ], + "pool": null, "required_resource_keys": [], "tags": {} }, @@ -2768,6 +2940,7 @@ "name": "result" } ], + "pool": null, "required_resource_keys": [], "tags": {} }, @@ -2795,6 +2968,7 @@ "name": "result" } ], + "pool": null, "required_resource_keys": [], "tags": {} }, @@ -2830,6 +3004,7 @@ "name": "fourth_kinds_key" } ], + "pool": null, "required_resource_keys": [], "tags": { "dagster/compute_kind": "python" @@ -2859,6 +3034,7 @@ "name": "result" } ], + "pool": null, "required_resource_keys": [], "tags": {} }, @@ -2886,6 +3062,7 @@ "name": "result" } ], + "pool": null, "required_resource_keys": [], "tags": {} }, @@ -2913,6 +3090,7 @@ "name": "result" } ], + "pool": null, "required_resource_keys": [], "tags": {} }, @@ -2947,6 +3125,7 @@ "name": "result" } ], + "pool": null, "required_resource_keys": [], "tags": {} }, @@ -2982,6 +3161,134 @@ "name": "check_in_op_asset_my_check" } ], + "pool": null, + "required_resource_keys": [], + "tags": {} + }, + { + "__class__": "SolidDefSnap", + "config_field_snap": { + "__class__": "ConfigFieldSnap", + "default_provided": false, + "default_value_as_json_str": null, + "description": null, + "is_required": false, + "name": "config", + "type_key": "Any" + }, + "description": null, + "input_def_snaps": [], + "name": "concurrency_asset", + "output_def_snaps": [ + { + "__class__": "OutputDefSnap", + "dagster_type_key": "Any", + "description": null, + "is_dynamic": false, + "is_required": true, + "name": "result" + } + ], + "pool": "foo", + "required_resource_keys": [], + "tags": {} + }, + { + "__class__": "SolidDefSnap", + "config_field_snap": { + "__class__": "ConfigFieldSnap", + "default_provided": true, + "default_value_as_json_str": "{}", + "description": null, + "is_required": false, + "name": "config", + "type_key": "Shape.da39a3ee5e6b4b0d3255bfef95601890afd80709" + }, + "description": null, + "input_def_snaps": [], + "name": "concurrency_multi_asset", + "output_def_snaps": [ + { + "__class__": "OutputDefSnap", + "dagster_type_key": "Nothing", + "description": null, + "is_dynamic": false, + "is_required": true, + "name": "concurrency_multi_asset_1" + }, + { + "__class__": "OutputDefSnap", + "dagster_type_key": "Nothing", + "description": null, + "is_dynamic": false, + "is_required": true, + "name": "concurrency_multi_asset_2" + } + ], + "pool": "buzz", + "required_resource_keys": [], + "tags": {} + }, + { + "__class__": "SolidDefSnap", + "config_field_snap": { + "__class__": "ConfigFieldSnap", + "default_provided": false, + "default_value_as_json_str": null, + "description": null, + "is_required": false, + "name": "config", + "type_key": "Any" + }, + "description": null, + "input_def_snaps": [], + "name": "concurrency_op_1", + "output_def_snaps": [ + { + "__class__": "OutputDefSnap", + "dagster_type_key": "Any", + "description": null, + "is_dynamic": false, + "is_required": true, + "name": "result" + } + ], + "pool": "bar", + "required_resource_keys": [], + "tags": {} + }, + { + "__class__": "SolidDefSnap", + "config_field_snap": { + "__class__": "ConfigFieldSnap", + "default_provided": false, + "default_value_as_json_str": null, + "description": null, + "is_required": false, + "name": "config", + "type_key": "Any" + }, + "description": null, + "input_def_snaps": [ + { + "__class__": "InputDefSnap", + "dagster_type_key": "Any", + "description": null, + "name": "input_1" + } + ], + "name": "concurrency_op_2", + "output_def_snaps": [ + { + "__class__": "OutputDefSnap", + "dagster_type_key": "Any", + "description": null, + "is_dynamic": false, + "is_required": true, + "name": "result" + } + ], + "pool": "baz", "required_resource_keys": [], "tags": {} }, @@ -3016,6 +3323,7 @@ "name": "result" } ], + "pool": null, "required_resource_keys": [], "tags": {} }, @@ -3050,6 +3358,7 @@ "name": "result" } ], + "pool": null, "required_resource_keys": [], "tags": {} }, @@ -3090,6 +3399,7 @@ "name": "result" } ], + "pool": null, "required_resource_keys": [], "tags": {} }, @@ -3124,6 +3434,7 @@ "name": "result" } ], + "pool": null, "required_resource_keys": [], "tags": {} }, @@ -3158,6 +3469,7 @@ "name": "result" } ], + "pool": null, "required_resource_keys": [], "tags": {} }, @@ -3192,6 +3504,7 @@ "name": "result" } ], + "pool": null, "required_resource_keys": [], "tags": {} }, @@ -3219,6 +3532,7 @@ "name": "result" } ], + "pool": null, "required_resource_keys": [], "tags": {} }, @@ -3253,6 +3567,7 @@ "name": "result" } ], + "pool": null, "required_resource_keys": [], "tags": {} }, @@ -3280,6 +3595,7 @@ "name": "result" } ], + "pool": null, "required_resource_keys": [], "tags": {} }, @@ -3314,6 +3630,7 @@ "name": "result" } ], + "pool": null, "required_resource_keys": [], "tags": {} }, @@ -3341,6 +3658,7 @@ "name": "result" } ], + "pool": null, "required_resource_keys": [], "tags": {} }, @@ -3381,6 +3699,7 @@ "name": "result" } ], + "pool": null, "required_resource_keys": [], "tags": {} }, @@ -3421,6 +3740,7 @@ "name": "result" } ], + "pool": null, "required_resource_keys": [], "tags": {} }, @@ -3455,6 +3775,7 @@ "name": "result" } ], + "pool": null, "required_resource_keys": [], "tags": {} }, @@ -3489,6 +3810,7 @@ "name": "result" } ], + "pool": null, "required_resource_keys": [], "tags": {} }, @@ -3523,6 +3845,7 @@ "name": "result" } ], + "pool": null, "required_resource_keys": [], "tags": {} }, @@ -3550,6 +3873,7 @@ "name": "result" } ], + "pool": null, "required_resource_keys": [], "tags": {} }, @@ -3577,6 +3901,7 @@ "name": "result" } ], + "pool": null, "required_resource_keys": [], "tags": {} }, @@ -3604,6 +3929,7 @@ "name": "result" } ], + "pool": null, "required_resource_keys": [], "tags": {} }, @@ -3638,6 +3964,7 @@ "name": "result" } ], + "pool": null, "required_resource_keys": [ "hanging_asset_resource" ], @@ -3674,6 +4001,7 @@ "name": "result" } ], + "pool": null, "required_resource_keys": [ "hanging_asset_resource" ], @@ -3703,6 +4031,7 @@ "name": "result" } ], + "pool": null, "required_resource_keys": [ "hanging_asset_resource" ], @@ -3732,6 +4061,7 @@ "name": "result" } ], + "pool": null, "required_resource_keys": [], "tags": {} }, @@ -3766,6 +4096,7 @@ "name": "result" } ], + "pool": null, "required_resource_keys": [], "tags": {} }, @@ -3800,6 +4131,7 @@ "name": "result" } ], + "pool": null, "required_resource_keys": [], "tags": {} }, @@ -3835,6 +4167,7 @@ "name": "second_kinds_key" } ], + "pool": null, "required_resource_keys": [], "tags": {} }, @@ -3862,6 +4195,7 @@ "name": "result" } ], + "pool": null, "required_resource_keys": [], "tags": {} }, @@ -3889,6 +4223,7 @@ "name": "result" } ], + "pool": null, "required_resource_keys": [], "tags": {} }, @@ -3923,6 +4258,7 @@ "name": "result" } ], + "pool": null, "required_resource_keys": [], "tags": {} }, @@ -3950,6 +4286,7 @@ "name": "result" } ], + "pool": null, "required_resource_keys": [], "tags": {} }, @@ -3977,6 +4314,7 @@ "name": "result" } ], + "pool": null, "required_resource_keys": [], "tags": {} }, @@ -4011,6 +4349,7 @@ "name": "result" } ], + "pool": null, "required_resource_keys": [], "tags": {} }, @@ -4045,6 +4384,7 @@ "name": "result" } ], + "pool": null, "required_resource_keys": [], "tags": {} }, @@ -4072,6 +4412,7 @@ "name": "result" } ], + "pool": null, "required_resource_keys": [], "tags": {} }, @@ -4099,6 +4440,7 @@ "name": "result" } ], + "pool": null, "required_resource_keys": [], "tags": {} }, @@ -4126,6 +4468,7 @@ "name": "result" } ], + "pool": null, "required_resource_keys": [ "hanging_asset_resource" ], @@ -4155,6 +4498,7 @@ "name": "result" } ], + "pool": null, "required_resource_keys": [], "tags": {} }, @@ -4206,6 +4550,7 @@ "name": "one_my_other_check" } ], + "pool": null, "required_resource_keys": [], "tags": {} }, @@ -4240,6 +4585,7 @@ "name": "result" } ], + "pool": null, "required_resource_keys": [], "tags": {} }, @@ -4275,6 +4621,7 @@ "name": "str_asset" } ], + "pool": null, "required_resource_keys": [], "tags": {} }, @@ -4302,6 +4649,7 @@ "name": "result" } ], + "pool": null, "required_resource_keys": [], "tags": {} }, @@ -4329,6 +4677,7 @@ "name": "result" } ], + "pool": null, "required_resource_keys": [], "tags": {} }, @@ -4356,6 +4705,7 @@ "name": "result" } ], + "pool": null, "required_resource_keys": [], "tags": {} }, @@ -4383,6 +4733,7 @@ "name": "result" } ], + "pool": null, "required_resource_keys": [], "tags": {} }, @@ -4417,6 +4768,7 @@ "name": "result" } ], + "pool": null, "required_resource_keys": [], "tags": {} }, @@ -4451,6 +4803,7 @@ "name": "result" } ], + "pool": null, "required_resource_keys": [], "tags": {} }, @@ -4478,6 +4831,7 @@ "name": "result" } ], + "pool": null, "required_resource_keys": [], "tags": {} }, @@ -4512,6 +4866,7 @@ "name": "result" } ], + "pool": null, "required_resource_keys": [], "tags": {} }, @@ -4539,6 +4894,7 @@ "name": "result" } ], + "pool": null, "required_resource_keys": [], "tags": {} }, @@ -4566,6 +4922,7 @@ "name": "result" } ], + "pool": null, "required_resource_keys": [], "tags": {} } @@ -5450,6 +5807,7 @@ "name": "result" } ], + "pool": null, "required_resource_keys": [], "tags": {} }, @@ -5484,6 +5842,7 @@ "name": "result" } ], + "pool": null, "required_resource_keys": [], "tags": {} } @@ -5494,7 +5853,7 @@ ''' # --- # name: test_all_snapshot_ids[101] - 'ab8f4b864ee53d2d9304b85f7a368aad7f678f29' + '769fc2d8acd27f4698b2c69c4be7c28c9f12ab70' # --- # name: test_all_snapshot_ids[102] ''' @@ -6341,6 +6700,7 @@ "name": "result" } ], + "pool": null, "required_resource_keys": [], "tags": {} } @@ -6351,7 +6711,7 @@ ''' # --- # name: test_all_snapshot_ids[103] - '98a8e544c66ff337c2aef1334603df0a3b1c7434' + '915d58f6d85c07bf073eb4a459c84cbf4fff70bc' # --- # name: test_all_snapshot_ids[104] ''' @@ -7376,6 +7736,7 @@ "name": "result" } ], + "pool": null, "required_resource_keys": [], "tags": {} } @@ -7386,7 +7747,7 @@ ''' # --- # name: test_all_snapshot_ids[105] - 'f53f6915917e179ab89bae44c345e79603f8d42d' + '2606adb830535b7009f9506f3b5fe8b2c54eb971' # --- # name: test_all_snapshot_ids[106] ''' @@ -8233,6 +8594,7 @@ "name": "result" } ], + "pool": null, "required_resource_keys": [], "tags": {} } @@ -8243,7 +8605,7 @@ ''' # --- # name: test_all_snapshot_ids[107] - 'd65a072229c6e8fc80db02c8d06067f3b0b48305' + '6ed1ee20c02e2765f51bbcc68bf9add6af5305ac' # --- # name: test_all_snapshot_ids[108] ''' @@ -9268,6 +9630,7 @@ "name": "result" } ], + "pool": null, "required_resource_keys": [], "tags": {} } @@ -9278,7 +9641,7 @@ ''' # --- # name: test_all_snapshot_ids[109] - '77bb631e77718a35cfd31049d03241709f9454ea' + '85e2679dc3c40934668114ca0a4ef1c2dda41a57' # --- # name: test_all_snapshot_ids[10] ''' @@ -11012,6 +11375,7 @@ "name": "result" } ], + "pool": null, "required_resource_keys": [ "hanging_asset_resource" ], @@ -11024,7 +11388,7 @@ ''' # --- # name: test_all_snapshot_ids[111] - 'c5cbcfa0e6f1c8658773ba21a9a70fd1b7c517eb' + '4dff0f381a4c32ce934bfdad3089ca7adb6ae4a7' # --- # name: test_all_snapshot_ids[112] ''' @@ -12049,6 +12413,7 @@ "name": "result" } ], + "pool": null, "required_resource_keys": [], "tags": {} } @@ -12059,7 +12424,7 @@ ''' # --- # name: test_all_snapshot_ids[113] - '8b0a6d0b6366a3178821e74b13782124ffa5d0fd' + '7685e700b5df952f2da8b5430c3ba3bc142d2863' # --- # name: test_all_snapshot_ids[114] ''' @@ -12906,6 +13271,7 @@ "name": "result" } ], + "pool": null, "required_resource_keys": [], "tags": {} } @@ -12916,7 +13282,7 @@ ''' # --- # name: test_all_snapshot_ids[115] - '88c326b7e07c8c537ecd8086fd6429436a46c66f' + 'e762100146993ec779a5fa784bf47d4aed7151eb' # --- # name: test_all_snapshot_ids[116] ''' @@ -13809,6 +14175,7 @@ "name": "result" } ], + "pool": null, "required_resource_keys": [], "tags": {} } @@ -13819,7 +14186,7 @@ ''' # --- # name: test_all_snapshot_ids[117] - 'a73f4941b2735f3a261d9617abaaed09a88aaebc' + '72c1d87c885853264966ae277c3d6dcdd1239d1a' # --- # name: test_all_snapshot_ids[118] ''' @@ -14712,6 +15079,7 @@ "name": "result" } ], + "pool": null, "required_resource_keys": [ "R1" ], @@ -14724,7 +15092,7 @@ ''' # --- # name: test_all_snapshot_ids[119] - '11f4785f61153adc6cca6935748af3807b59eee9' + 'e2e8e72f3582e1a2eae7382944855471a6bc602a' # --- # name: test_all_snapshot_ids[11] 'cd81ec29a7fde8a337dc04fb109dd707a2962d18' @@ -15620,6 +15988,7 @@ "name": "result" } ], + "pool": null, "required_resource_keys": [ "R1" ], @@ -15632,7 +16001,7 @@ ''' # --- # name: test_all_snapshot_ids[121] - '2b43566d7b3de2138b12c91b6953d6f1ddde0140' + 'c86d5fe8c2541af9f50ae935ff37aa065151dc63' # --- # name: test_all_snapshot_ids[122] ''' @@ -16657,6 +17026,7 @@ "name": "result" } ], + "pool": null, "required_resource_keys": [ "disable_gc" ], @@ -16693,6 +17063,7 @@ "name": "result" } ], + "pool": null, "required_resource_keys": [ "disable_gc" ], @@ -16722,6 +17093,7 @@ "name": "result" } ], + "pool": null, "required_resource_keys": [], "tags": {} }, @@ -16762,6 +17134,7 @@ "name": "result" } ], + "pool": null, "required_resource_keys": [], "tags": {} } @@ -16772,7 +17145,7 @@ ''' # --- # name: test_all_snapshot_ids[123] - 'b07b89c1664d4a248bc1a39974a91b31d8956c54' + '28b691accda6c56db71e3383fbb09c528da3d866' # --- # name: test_all_snapshot_ids[124] ''' @@ -17830,6 +18203,7 @@ "name": "start_skip" } ], + "pool": null, "required_resource_keys": [], "tags": {} }, @@ -17865,6 +18239,7 @@ "name": "skip" } ], + "pool": null, "required_resource_keys": [], "tags": {} }, @@ -17890,6 +18265,7 @@ ], "name": "no_output", "output_def_snaps": [], + "pool": null, "required_resource_keys": [], "tags": {} }, @@ -17924,6 +18300,7 @@ "name": "result" } ], + "pool": null, "required_resource_keys": [], "tags": {} } @@ -17934,7 +18311,7 @@ ''' # --- # name: test_all_snapshot_ids[125] - '9a9a09da6b3a1dbab13bfde5e155c0f097dd22a5' + 'c835b5ac4189eafef207b267f933fd97123cb365' # --- # name: test_all_snapshot_ids[126] ''' @@ -18857,6 +19234,7 @@ "name": "result" } ], + "pool": null, "required_resource_keys": [ "a" ], @@ -18893,6 +19271,7 @@ "name": "result" } ], + "pool": null, "required_resource_keys": [ "b" ], @@ -18905,7 +19284,7 @@ ''' # --- # name: test_all_snapshot_ids[127] - 'b131f0bc1872f377636fbf002a3ad86049c1e8af' + '775a4c5ea46104e3a1ff9db07a8bd083468c2b20' # --- # name: test_all_snapshot_ids[128] ''' @@ -19803,6 +20182,7 @@ "name": "result" } ], + "pool": null, "required_resource_keys": [], "tags": {} }, @@ -19830,6 +20210,7 @@ "name": "result" } ], + "pool": null, "required_resource_keys": [], "tags": {} }, @@ -19857,6 +20238,7 @@ "name": "result" } ], + "pool": null, "required_resource_keys": [], "tags": {} }, @@ -19884,6 +20266,7 @@ "name": "result" } ], + "pool": null, "required_resource_keys": [], "tags": {} } @@ -19894,7 +20277,7 @@ ''' # --- # name: test_all_snapshot_ids[129] - 'ca68b52613bfcadc230b3dc1ec7e1045f9bc5836' + '70918a742d3ab528c6bcc6cd7b78e20fd6bb8e3a' # --- # name: test_all_snapshot_ids[12] ''' @@ -20808,6 +21191,7 @@ "name": "result" } ], + "pool": null, "required_resource_keys": [], "tags": {} }, @@ -20835,6 +21219,7 @@ "name": "result" } ], + "pool": null, "required_resource_keys": [], "tags": {} }, @@ -20869,6 +21254,7 @@ "name": "result" } ], + "pool": null, "required_resource_keys": [], "tags": {} } @@ -21723,6 +22109,7 @@ "name": "result" } ], + "pool": null, "required_resource_keys": [], "tags": {} } @@ -21733,7 +22120,7 @@ ''' # --- # name: test_all_snapshot_ids[131] - '4fbe2b21985de715173a8d630c5d1506a0c7f040' + '928c0e7fa6489a9994d16215ef968ccafa0d0679' # --- # name: test_all_snapshot_ids[132] ''' @@ -22580,6 +22967,7 @@ "name": "result" } ], + "pool": null, "required_resource_keys": [], "tags": {} } @@ -22590,7 +22978,7 @@ ''' # --- # name: test_all_snapshot_ids[133] - 'c58bbee5967b5e43b907f2ee09bfa26b5b017899' + 'fdde90a39d165ebd07fc39556c7a9b4af1e44f13' # --- # name: test_all_snapshot_ids[134] ''' @@ -23437,6 +23825,7 @@ "name": "result" } ], + "pool": null, "required_resource_keys": [], "tags": {} } @@ -23447,7 +23836,7 @@ ''' # --- # name: test_all_snapshot_ids[135] - '9109ebc6447db70cdcd17a7bf8b90ec61ffd02fe' + 'a23753e6c511ccff1f07d05304a6f7f0a832a116' # --- # name: test_all_snapshot_ids[136] ''' @@ -24294,6 +24683,7 @@ "name": "result" } ], + "pool": null, "required_resource_keys": [], "tags": {} } @@ -24304,7 +24694,7 @@ ''' # --- # name: test_all_snapshot_ids[137] - '673ec5c1c0fce5ffec0506edd32bcdbd018e79bb' + 'e2f9e2e1e6719a79f8bc336bac4521c8d0136655' # --- # name: test_all_snapshot_ids[138] ''' @@ -25451,6 +25841,7 @@ "name": "result" } ], + "pool": null, "required_resource_keys": [], "tags": {} }, @@ -25485,6 +25876,7 @@ "name": "result" } ], + "pool": null, "required_resource_keys": [], "tags": {} }, @@ -25519,6 +25911,7 @@ "name": "result" } ], + "pool": null, "required_resource_keys": [], "tags": {} }, @@ -25553,6 +25946,7 @@ "name": "result" } ], + "pool": null, "required_resource_keys": [], "tags": {} } @@ -25563,10 +25957,10 @@ ''' # --- # name: test_all_snapshot_ids[139] - 'ea8e78a81a6c470713834d21c023ab1d45d00394' + 'f9ad400e36d87bf80246971be128612ea622ca2c' # --- # name: test_all_snapshot_ids[13] - '1f3478e419b57370edfc5959b967300b91ad776c' + 'a86aacf9a2c9d233cab329983796e55ae6e6805c' # --- # name: test_all_snapshot_ids[140] ''' @@ -26413,6 +26807,7 @@ "name": "result" } ], + "pool": null, "required_resource_keys": [], "tags": {} } @@ -26423,7 +26818,7 @@ ''' # --- # name: test_all_snapshot_ids[141] - '927cbfcff5af3bd40ebed1cae3eed1baf4c3547f' + '83c6ac6d0dfa042821973ee0e8c432e9cb462e11' # --- # name: test_all_snapshot_ids[142] ''' @@ -27273,6 +27668,7 @@ "name": "result" } ], + "pool": null, "required_resource_keys": [], "tags": {} } @@ -27285,7 +27681,7 @@ ''' # --- # name: test_all_snapshot_ids[143] - 'c3320c44d5fa6c508dfda564e67bc67747b9891c' + 'cd65ddea2cf05735d3afd0d5a754bb480701540d' # --- # name: test_all_snapshot_ids[144] ''' @@ -28347,6 +28743,7 @@ "name": "result" } ], + "pool": null, "required_resource_keys": [], "tags": {} }, @@ -28374,6 +28771,7 @@ "name": "result" } ], + "pool": null, "required_resource_keys": [], "tags": {} } @@ -28384,7 +28782,7 @@ ''' # --- # name: test_all_snapshot_ids[145] - '81ecba8b867d1179f0998c86b85a1176aa946456' + '547f39e0de84614590c1247c5c8f646696153dcd' # --- # name: test_all_snapshot_ids[146] ''' @@ -29439,6 +29837,7 @@ "name": "result" } ], + "pool": null, "required_resource_keys": [], "tags": {} }, @@ -29473,6 +29872,7 @@ "name": "result" } ], + "pool": null, "required_resource_keys": [], "tags": {} } @@ -29483,7 +29883,7 @@ ''' # --- # name: test_all_snapshot_ids[147] - 'ce839b23a887f29520c71238335886cbe80337ef' + 'c12ff78fede2ed02f9f73a531003b65b262f85b3' # --- # name: test_all_snapshot_ids[148] ''' @@ -30389,6 +30789,7 @@ "name": "result" } ], + "pool": null, "required_resource_keys": [], "tags": {} }, @@ -30416,6 +30817,7 @@ "name": "result" } ], + "pool": null, "required_resource_keys": [], "tags": {} }, @@ -30456,6 +30858,7 @@ "name": "result" } ], + "pool": null, "required_resource_keys": [], "tags": {} } @@ -30466,7 +30869,7 @@ ''' # --- # name: test_all_snapshot_ids[149] - '4b4b18dca82ef0567492f476ff2bcbbf7392206d' + '9c9eca490a1c758490dcd538469321bef142615f' # --- # name: test_all_snapshot_ids[14] ''' @@ -31538,6 +31941,7 @@ "name": "one_my_other_check" } ], + "pool": null, "required_resource_keys": [], "tags": {} } @@ -32660,6 +33064,7 @@ "name": "result" } ], + "pool": null, "required_resource_keys": [], "tags": {} }, @@ -32695,6 +33100,7 @@ "name": "str_asset" } ], + "pool": null, "required_resource_keys": [], "tags": {} }, @@ -32729,6 +33135,7 @@ "name": "result" } ], + "pool": null, "required_resource_keys": [], "tags": {} } @@ -32739,10 +33146,10 @@ ''' # --- # name: test_all_snapshot_ids[151] - 'dedb9fc5a6627950d8d31dce78af887c18c25160' + '927ec3de2eafb5ea326d481adbfa6f108d896bca' # --- # name: test_all_snapshot_ids[15] - 'c77559c3ffec162d2580606b6cc7aeaf8ab8d9e0' + 'b0c06b1d19ebc1719fb97e606c97c98808173120' # --- # name: test_all_snapshot_ids[16] ''' @@ -33660,6 +34067,7 @@ "name": "result" } ], + "pool": null, "required_resource_keys": [], "tags": {} } @@ -33670,7 +34078,7 @@ ''' # --- # name: test_all_snapshot_ids[17] - 'ac30d35b2d3b8c25490824aaa8dac2281ad4f860' + '2f4a7e8dac16272a9e008a61e766b43bd473eb7e' # --- # name: test_all_snapshot_ids[18] ''' @@ -35005,6 +35413,7 @@ "name": "result" } ], + "pool": null, "required_resource_keys": [], "tags": {} }, @@ -35039,6 +35448,7 @@ "name": "result" } ], + "pool": null, "required_resource_keys": [], "tags": {} } @@ -35049,10 +35459,10 @@ ''' # --- # name: test_all_snapshot_ids[19] - 'd9f6d85793df3d9df94d4aedb21bb659c1202bda' + 'f726acb538de96f43dfa0335f7bc79d1b52394c1' # --- # name: test_all_snapshot_ids[1] - 'e3c865407ca4b1623f7d29ccbdc56d77a3da497b' + '63121a087cbde7bf0ad100080e12267a7592b272' # --- # name: test_all_snapshot_ids[20] ''' @@ -36081,6 +36491,7 @@ "name": "result" } ], + "pool": null, "required_resource_keys": [], "tags": {} }, @@ -36108,6 +36519,7 @@ "name": "result" } ], + "pool": null, "required_resource_keys": [], "tags": {} } @@ -36118,7 +36530,7 @@ ''' # --- # name: test_all_snapshot_ids[21] - '9041a32e00b2c27d78e168f10272a992f819e88d' + 'a380036718142da0ac2761aa86d24ae2c0f96f53' # --- # name: test_all_snapshot_ids[22] ''' @@ -37078,6 +37490,7 @@ "name": "result" } ], + "pool": null, "required_resource_keys": [], "tags": {} }, @@ -37112,6 +37525,7 @@ "name": "result" } ], + "pool": null, "required_resource_keys": [], "tags": {} } @@ -37122,7 +37536,7 @@ ''' # --- # name: test_all_snapshot_ids[23] - '9d2930f7c072c5a01688d84b725c49d4ae718c65' + '42f2f9908dcf606a04364fd6edab7bd9a1e39aa4' # --- # name: test_all_snapshot_ids[24] ''' @@ -38082,6 +38496,7 @@ "name": "result" } ], + "pool": null, "required_resource_keys": [], "tags": {} }, @@ -38116,6 +38531,7 @@ "name": "result" } ], + "pool": null, "required_resource_keys": [], "tags": {} } @@ -38126,7 +38542,7 @@ ''' # --- # name: test_all_snapshot_ids[25] - 'a28dd9e490e08f05fab6ab1309de27da5cd3eb0f' + '55ca8157660c610a531746808060e545b83c6247' # --- # name: test_all_snapshot_ids[26] ''' @@ -39056,6 +39472,7 @@ "name": "result" } ], + "pool": null, "required_resource_keys": [], "tags": {} } @@ -39066,7 +39483,7 @@ ''' # --- # name: test_all_snapshot_ids[27] - 'a62baecf830886bfa322863f86bbd7344ef9c359' + '3d4925a65348e3a0560aa6b818aa958098967525' # --- # name: test_all_snapshot_ids[28] ''' @@ -40056,6 +40473,7 @@ "name": "result" } ], + "pool": null, "required_resource_keys": [], "tags": {} }, @@ -40090,6 +40508,7 @@ "name": "result" } ], + "pool": null, "required_resource_keys": [], "tags": {} }, @@ -40124,6 +40543,7 @@ "name": "result" } ], + "pool": null, "required_resource_keys": [], "tags": {} } @@ -40134,7 +40554,7 @@ ''' # --- # name: test_all_snapshot_ids[29] - '2bc0dc6a7c8ccb4ec4352fde1925f82521d71675' + '65d1097db8175b8dccef024c87c948f207cdb11f' # --- # name: test_all_snapshot_ids[2] ''' @@ -41159,6 +41579,7 @@ "name": "result" } ], + "pool": null, "required_resource_keys": [], "tags": {} } @@ -42013,6 +42434,7 @@ "name": "result" } ], + "pool": null, "required_resource_keys": [], "tags": {} } @@ -42023,7 +42445,7 @@ ''' # --- # name: test_all_snapshot_ids[31] - '458a303a0e8d51f99eb8417d4be851f0b982b5a5' + '3ee8302845c25b0527561794e22024de90478a04' # --- # name: test_all_snapshot_ids[32] ''' @@ -43085,6 +43507,7 @@ "name": "result" } ], + "pool": null, "required_resource_keys": [], "tags": {} }, @@ -43112,6 +43535,7 @@ "name": "result" } ], + "pool": null, "required_resource_keys": [], "tags": {} } @@ -43122,7 +43546,7 @@ ''' # --- # name: test_all_snapshot_ids[33] - '155cb67915656dd22c1d24cac01603648f423b0b' + '702d508e8721e8c8286c056f5a0a888c1febb1da' # --- # name: test_all_snapshot_ids[34] ''' @@ -44179,6 +44603,7 @@ "name": "result" } ], + "pool": null, "required_resource_keys": [], "tags": {} }, @@ -44206,6 +44631,7 @@ "name": "result" } ], + "pool": null, "required_resource_keys": [], "tags": {} }, @@ -44240,6 +44666,7 @@ "name": "result" } ], + "pool": null, "required_resource_keys": [], "tags": {} }, @@ -44286,6 +44713,7 @@ "name": "result" } ], + "pool": null, "required_resource_keys": [], "tags": {} }, @@ -44320,6 +44748,7 @@ "name": "result" } ], + "pool": null, "required_resource_keys": [], "tags": {} } @@ -44330,7 +44759,7 @@ ''' # --- # name: test_all_snapshot_ids[35] - 'db3c9e009bad031bbf9b5f278cc09b691a00eaec' + 'e3cf4257cb43e1a09b7dbfb4878d44bd40e30798' # --- # name: test_all_snapshot_ids[36] ''' @@ -45392,6 +45821,7 @@ "name": "result" } ], + "pool": null, "required_resource_keys": [], "tags": {} }, @@ -45419,6 +45849,7 @@ "name": "result" } ], + "pool": null, "required_resource_keys": [], "tags": {} } @@ -45429,7 +45860,7 @@ ''' # --- # name: test_all_snapshot_ids[37] - '226bfaa0b42ce356abd18ab86046686cc2c2b9b2' + 'a1d2b3ec611aced3a1efde71401cded7594ac075' # --- # name: test_all_snapshot_ids[38] ''' @@ -46543,6 +46974,7 @@ "name": "result" } ], + "pool": null, "required_resource_keys": [], "tags": {} }, @@ -46577,6 +47009,7 @@ "name": "result" } ], + "pool": null, "required_resource_keys": [ "retry_count" ], @@ -46613,6 +47046,7 @@ "name": "result" } ], + "pool": null, "required_resource_keys": [], "tags": {} }, @@ -46640,6 +47074,7 @@ "name": "result" } ], + "pool": null, "required_resource_keys": [], "tags": {} } @@ -46650,10 +47085,10 @@ ''' # --- # name: test_all_snapshot_ids[39] - 'effe11fd9b8a40682bc8041fcfdaf25f68be4612' + 'cdea9b63b71ce76a1db61539dd7040f69d52590c' # --- # name: test_all_snapshot_ids[3] - 'fc5c2d069b423eb651fd1b8e68f1537d8ecfdd82' + 'b3476cfa8240e1713d78897fdfec25a59b64f0df' # --- # name: test_all_snapshot_ids[40] ''' @@ -47692,6 +48127,7 @@ "name": "result" } ], + "pool": null, "required_resource_keys": [], "tags": {} } @@ -47702,7 +48138,7 @@ ''' # --- # name: test_all_snapshot_ids[41] - '5c546683c0858a71f27c63a4b294926e1de6a1e1' + '1044db6796f43e8732d5971f0024ca36faf9885c' # --- # name: test_all_snapshot_ids[42] ''' @@ -48727,6 +49163,7 @@ "name": "result" } ], + "pool": null, "required_resource_keys": [], "tags": {} } @@ -48737,7 +49174,7 @@ ''' # --- # name: test_all_snapshot_ids[43] - '39c8061a712382691a1d8203efadcec978be2173' + 'ba40a7cc6906899c438abe67f5144f720ead2158' # --- # name: test_all_snapshot_ids[44] ''' @@ -49863,6 +50300,7 @@ "name": "result" } ], + "pool": null, "required_resource_keys": [], "tags": {} }, @@ -49903,6 +50341,7 @@ "name": "result" } ], + "pool": null, "required_resource_keys": [], "tags": {} }, @@ -49937,6 +50376,7 @@ "name": "result" } ], + "pool": null, "required_resource_keys": [], "tags": {} }, @@ -49971,6 +50411,7 @@ "name": "result" } ], + "pool": null, "required_resource_keys": [], "tags": {} } @@ -49981,7 +50422,7 @@ ''' # --- # name: test_all_snapshot_ids[45] - 'f07b5f3e9fe1aaec2d455ef01bac50f38db70300' + '0419f0d2bcee4b7d82c749b41ffde27d3e841669' # --- # name: test_all_snapshot_ids[46] ''' @@ -51112,6 +51553,7 @@ "name": "result" } ], + "pool": null, "required_resource_keys": [], "tags": {} }, @@ -51146,6 +51588,7 @@ "name": "result" } ], + "pool": null, "required_resource_keys": [], "tags": {} }, @@ -51173,6 +51616,7 @@ "name": "result" } ], + "pool": null, "required_resource_keys": [], "tags": {} }, @@ -51213,6 +51657,7 @@ "name": "result" } ], + "pool": null, "required_resource_keys": [], "tags": {} }, @@ -51240,6 +51685,7 @@ "name": "result" } ], + "pool": null, "required_resource_keys": [], "tags": {} } @@ -51250,7 +51696,7 @@ ''' # --- # name: test_all_snapshot_ids[47] - '7ba20030eeecab26afcfd3cd5a68be1d2f48c427' + 'cbc9b73edbfb16e68bfaea0cf9b96849bceb8768' # --- # name: test_all_snapshot_ids[48] ''' @@ -52397,6 +52843,7 @@ "name": "result" } ], + "pool": null, "required_resource_keys": [], "tags": {} }, @@ -52431,6 +52878,7 @@ "name": "result" } ], + "pool": null, "required_resource_keys": [], "tags": {} }, @@ -52465,6 +52913,7 @@ "name": "result" } ], + "pool": null, "required_resource_keys": [], "tags": {} }, @@ -52499,6 +52948,7 @@ "name": "result" } ], + "pool": null, "required_resource_keys": [], "tags": {} } @@ -52509,7 +52959,7 @@ ''' # --- # name: test_all_snapshot_ids[49] - 'a670207753e19f723023819135333b4ac71a281b' + '3f6c8ba6993e3c2d8ef331327dfe6bcdec3d1e39' # --- # name: test_all_snapshot_ids[4] ''' @@ -53534,6 +53984,7 @@ "name": "result" } ], + "pool": null, "required_resource_keys": [], "tags": {} } @@ -54750,6 +55201,7 @@ "name": "result" } ], + "pool": null, "required_resource_keys": [], "tags": {} }, @@ -54784,6 +55236,7 @@ "name": "result" } ], + "pool": null, "required_resource_keys": [ "hanging_asset_resource" ], @@ -54813,6 +55266,7 @@ "name": "result" } ], + "pool": null, "required_resource_keys": [], "tags": {} }, @@ -54847,6 +55301,7 @@ "name": "result" } ], + "pool": null, "required_resource_keys": [], "tags": {} } @@ -54857,7 +55312,7 @@ ''' # --- # name: test_all_snapshot_ids[51] - '8d5778a9040bf5a8f2eb894cca019573f72cafb7' + '709d40d76a7309b11219cb331842fb349e161eb0' # --- # name: test_all_snapshot_ids[52] ''' @@ -55871,6 +56326,7 @@ "name": "result" } ], + "pool": null, "required_resource_keys": [], "tags": {} }, @@ -55905,6 +56361,7 @@ "name": "result" } ], + "pool": null, "required_resource_keys": [ "hanging_asset_resource" ], @@ -55941,6 +56398,7 @@ "name": "result" } ], + "pool": null, "required_resource_keys": [], "tags": {} } @@ -55951,7 +56409,7 @@ ''' # --- # name: test_all_snapshot_ids[53] - '2a4c830fed93036921f36e4ff15172e452f21460' + 'c3aabf70377cb5b0e29bbb20fd4fcf3e19a31243' # --- # name: test_all_snapshot_ids[54] ''' @@ -56891,6 +57349,7 @@ "name": "result" } ], + "pool": null, "required_resource_keys": [ "hanging_asset_resource" ], @@ -56903,7 +57362,7 @@ ''' # --- # name: test_all_snapshot_ids[55] - '3fcb711d337cb03bedf5ff7e5ec64b30eefc9ec8' + 'feee923ea5fe7d6c6a32a7bcb5520580968b172b' # --- # name: test_all_snapshot_ids[56] ''' @@ -57856,6 +58315,7 @@ "name": "result" } ], + "pool": null, "required_resource_keys": [ "hanging_asset_resource" ], @@ -57885,6 +58345,7 @@ "name": "result" } ], + "pool": null, "required_resource_keys": [], "tags": {} } @@ -57895,7 +58356,7 @@ ''' # --- # name: test_all_snapshot_ids[57] - 'b467f29b8fb76fd793f23aa1cefb10918a105f91' + '02b4161e051e81f1c2a6d98a9e4fd317dfdebcb6' # --- # name: test_all_snapshot_ids[58] ''' @@ -58818,6 +59279,7 @@ "name": "result" } ], + "pool": null, "required_resource_keys": [], "tags": {} }, @@ -58852,6 +59314,7 @@ "name": "result" } ], + "pool": null, "required_resource_keys": [], "tags": {} } @@ -58862,10 +59325,10 @@ ''' # --- # name: test_all_snapshot_ids[59] - 'c6b504611b1ee7582092807ac90bdd4ac64bac3b' + 'c3ee2f13236f5c435fd35cda5130aee26f782ba6' # --- # name: test_all_snapshot_ids[5] - 'c23e75a6d1d7a9b89528399a9d27bcc9c90a178e' + 'caa77ddbcfcd5b19d2aa3a79f590ebdbf08d0e93' # --- # name: test_all_snapshot_ids[60] ''' @@ -59712,6 +60175,7 @@ "name": "result" } ], + "pool": null, "required_resource_keys": [], "tags": {} } @@ -59724,7 +60188,7 @@ ''' # --- # name: test_all_snapshot_ids[61] - 'dc190868e8887ba5ac3669da13473252cd0ab098' + 'aa4ef476a6365f3e0580260a76a6d6d68230f1ba' # --- # name: test_all_snapshot_ids[62] ''' @@ -60617,6 +61081,7 @@ "name": "result" } ], + "pool": null, "required_resource_keys": [], "tags": {} } @@ -60627,7 +61092,7 @@ ''' # --- # name: test_all_snapshot_ids[63] - '83469e8c700778e0c1e268f158672fca54d5896b' + 'ef3bed708c084bf42ea5a6323e0956535baa4543' # --- # name: test_all_snapshot_ids[64] ''' @@ -61474,6 +61939,7 @@ "name": "result" } ], + "pool": null, "required_resource_keys": [], "tags": {} } @@ -61484,7 +61950,7 @@ ''' # --- # name: test_all_snapshot_ids[65] - 'c4fee3a0c56b1ef6fcea9b64ceaacd06c4d5e216' + 'd0384ede0cce61753aaeb41ca23c890fe92056ff' # --- # name: test_all_snapshot_ids[66] ''' @@ -62509,6 +62975,7 @@ "name": "result" } ], + "pool": null, "required_resource_keys": [], "tags": {} } @@ -62519,7 +62986,7 @@ ''' # --- # name: test_all_snapshot_ids[67] - '10e316cc85a348c2e9f5c5ec1a076bfe7e036ff2' + 'd80307a63854223bed7bb3ee68a98bcc8dd1e910' # --- # name: test_all_snapshot_ids[68] ''' @@ -63412,6 +63879,7 @@ "name": "result" } ], + "pool": null, "required_resource_keys": [], "tags": {} } @@ -63422,7 +63890,7 @@ ''' # --- # name: test_all_snapshot_ids[69] - '643e2b02ca69b0087d15b448a9108d39d5b35036' + 'b7bb430ea92805bcde137dfd09f72b84d7d5e073' # --- # name: test_all_snapshot_ids[6] ''' @@ -64500,6 +64968,7 @@ "name": "result" } ], + "pool": null, "required_resource_keys": [], "tags": {} }, @@ -64540,6 +65009,7 @@ "name": "result" } ], + "pool": null, "required_resource_keys": [], "tags": {} }, @@ -64575,6 +65045,7 @@ "name": "check_in_op_asset_my_check" } ], + "pool": null, "required_resource_keys": [], "tags": {} } @@ -65481,6 +65952,7 @@ "name": "result" } ], + "pool": null, "required_resource_keys": [], "tags": {} } @@ -65491,7 +65963,7 @@ ''' # --- # name: test_all_snapshot_ids[71] - '158a79ab642707e63923c59c6abaf7960b36211e' + '000261a9954723ac0cefe107bc92adcf0e3a200b' # --- # name: test_all_snapshot_ids[72] ''' @@ -66363,6 +66835,7 @@ "input_def_snaps": [], "name": "emit_failed_expectation", "output_def_snaps": [], + "pool": null, "required_resource_keys": [], "tags": {} }, @@ -66381,6 +66854,7 @@ "input_def_snaps": [], "name": "emit_successful_expectation", "output_def_snaps": [], + "pool": null, "required_resource_keys": [], "tags": {} }, @@ -66399,6 +66873,7 @@ "input_def_snaps": [], "name": "emit_successful_expectation_no_metadata", "output_def_snaps": [], + "pool": null, "required_resource_keys": [], "tags": {} } @@ -66409,7 +66884,7 @@ ''' # --- # name: test_all_snapshot_ids[73] - '25eed9832eef95ee97a63357e836659193775b3d' + '6d22707948b2ee20673d0b3108d83b1c4f3d7afd' # --- # name: test_all_snapshot_ids[74] ''' @@ -67347,6 +67822,7 @@ "name": "bar" } ], + "pool": null, "required_resource_keys": [], "tags": {} } @@ -67357,7 +67833,7 @@ ''' # --- # name: test_all_snapshot_ids[75] - '6069db2378a5bcd370c5f8ce8e8ee51d997e3447' + 'f265b9e6e67079d19d46aa0d652a879c6fbec8ef' # --- # name: test_all_snapshot_ids[76] ''' @@ -68255,6 +68731,7 @@ "name": "result" } ], + "pool": null, "required_resource_keys": [], "tags": {} }, @@ -68282,6 +68759,7 @@ "name": "result" } ], + "pool": null, "required_resource_keys": [], "tags": {} } @@ -68292,7 +68770,7 @@ ''' # --- # name: test_all_snapshot_ids[77] - 'de3cee0b30bf45c5c28b57035caff8a592cb8a99' + '5dd48aa61f869698d9a41066631b480e451bf4a8' # --- # name: test_all_snapshot_ids[78] ''' @@ -69168,6 +69646,7 @@ "input_def_snaps": [], "name": "op_with_list", "output_def_snaps": [], + "pool": null, "required_resource_keys": [], "tags": {} } @@ -69178,10 +69657,10 @@ ''' # --- # name: test_all_snapshot_ids[79] - '68f90c6bc3483e01ab1317573d90e23d0efe14a9' + '40a335f6458b99a0e8ece9e2438437ff0851bf6c' # --- # name: test_all_snapshot_ids[7] - '8023256507d183317343a2f6c4703a5ac3800eaf' + '4cbb3779564cdebc3594f0edd5c94950ec92f778' # --- # name: test_all_snapshot_ids[80] ''' @@ -70074,6 +70553,7 @@ "name": "result" } ], + "pool": null, "required_resource_keys": [], "tags": {} } @@ -70084,7 +70564,7 @@ ''' # --- # name: test_all_snapshot_ids[81] - '1c4b82d393f7eacd9a358e3d82925d2afb9afbc0' + '6bb72c4b253804f1387776ea54c767fd97923f0d' # --- # name: test_all_snapshot_ids[82] ''' @@ -70931,6 +71411,7 @@ "name": "result" } ], + "pool": null, "required_resource_keys": [], "tags": {} } @@ -70941,7 +71422,7 @@ ''' # --- # name: test_all_snapshot_ids[83] - 'ab213b2b0286d659e9d7044d7dcec9b13d5b8bc7' + '12f5edfb1605d122c4e3628a8481844db5d772ce' # --- # name: test_all_snapshot_ids[84] ''' @@ -71869,6 +72350,7 @@ "name": "result" } ], + "pool": null, "required_resource_keys": [], "tags": {} }, @@ -71896,6 +72378,7 @@ "name": "result" } ], + "pool": null, "required_resource_keys": [], "tags": {} } @@ -71906,7 +72389,7 @@ ''' # --- # name: test_all_snapshot_ids[85] - '06068d3cd0c89f54330c52e56f4e72a338f19a9f' + '9717dc0073cae0d9772818a7097d4cf71c2892fe' # --- # name: test_all_snapshot_ids[86] ''' @@ -72897,6 +73380,7 @@ "input_def_snaps": [], "name": "op_with_multilayered_config", "output_def_snaps": [], + "pool": null, "required_resource_keys": [], "tags": {} } @@ -72907,7 +73391,7 @@ ''' # --- # name: test_all_snapshot_ids[87] - '10cfd966244a4e4064ff00517d3e012ad6ce4c7d' + '947292f5870d5ca8a8dcf99a66f9d7759f2f5646' # --- # name: test_all_snapshot_ids[88] ''' @@ -73784,6 +74268,7 @@ "name": "result" } ], + "pool": null, "required_resource_keys": [], "tags": {} }, @@ -73818,6 +74303,7 @@ "name": "result" } ], + "pool": null, "required_resource_keys": [], "tags": {} } @@ -73828,7 +74314,7 @@ ''' # --- # name: test_all_snapshot_ids[89] - 'b7499dc1851fe912eb84bbbcead7d7db511e64d8' + '4eb442f45da611e54320f4cc5084f41a2f1f1a86' # --- # name: test_all_snapshot_ids[8] ''' @@ -74675,6 +75161,7 @@ "name": "result" } ], + "pool": null, "required_resource_keys": [], "tags": {} } @@ -75707,6 +76194,7 @@ "name": "result" } ], + "pool": null, "required_resource_keys": [], "tags": {} } @@ -75717,7 +76205,7 @@ ''' # --- # name: test_all_snapshot_ids[91] - '17bea22424bd5aa8995cc8ae08cd2e0c1be7c019' + '65a943726ccddf0851318d8255849c6a27687b60' # --- # name: test_all_snapshot_ids[92] ''' @@ -76772,6 +77260,7 @@ "name": "result" } ], + "pool": null, "required_resource_keys": [], "tags": {} }, @@ -76806,6 +77295,7 @@ "name": "result" } ], + "pool": null, "required_resource_keys": [], "tags": {} } @@ -76816,7 +77306,7 @@ ''' # --- # name: test_all_snapshot_ids[93] - '7fc53a5a9f9ab514b23b938f7fa68cd5fd2f464d' + '15eee9b4a572e4b6eddd9ed0ec8fcc34e3d96e59' # --- # name: test_all_snapshot_ids[94] ''' @@ -77909,6 +78399,7 @@ "name": "result" } ], + "pool": null, "required_resource_keys": [], "tags": {} }, @@ -77936,6 +78427,7 @@ "name": "result" } ], + "pool": null, "required_resource_keys": [], "tags": {} }, @@ -77963,6 +78455,7 @@ "name": "result" } ], + "pool": null, "required_resource_keys": [], "tags": {} }, @@ -77990,6 +78483,7 @@ "name": "result" } ], + "pool": null, "required_resource_keys": [], "tags": {} }, @@ -78017,6 +78511,7 @@ "name": "result" } ], + "pool": null, "required_resource_keys": [], "tags": {} } @@ -78027,7 +78522,7 @@ ''' # --- # name: test_all_snapshot_ids[95] - 'f08d1a06b69649912ba8b056d76b8c7809954c31' + '11b9c9be70b3ce0434a5ea9aca6a52547da2ed73' # --- # name: test_all_snapshot_ids[96] ''' @@ -78874,6 +79369,7 @@ "name": "result" } ], + "pool": null, "required_resource_keys": [], "tags": {} } @@ -78884,7 +79380,7 @@ ''' # --- # name: test_all_snapshot_ids[97] - '913c310b609478d52a81ee83bdd4b095d0f2932d' + '2de4122175e786573bf2870c54af3189990ceb77' # --- # name: test_all_snapshot_ids[98] ''' @@ -79950,6 +80446,7 @@ "name": "result" } ], + "pool": null, "required_resource_keys": [], "tags": {} }, @@ -79977,6 +80474,7 @@ "name": "result" } ], + "pool": null, "required_resource_keys": [], "tags": {} }, @@ -80004,6 +80502,7 @@ "name": "result" } ], + "pool": null, "required_resource_keys": [], "tags": {} }, @@ -80038,6 +80537,7 @@ "name": "result" } ], + "pool": null, "required_resource_keys": [], "tags": {} } @@ -80048,8 +80548,8 @@ ''' # --- # name: test_all_snapshot_ids[99] - '8e137c24b2245e55025e1cc7b71a42b99425dbec' + 'cf140114fda778cc12c11ba13f7e26cd0fbccb3c' # --- # name: test_all_snapshot_ids[9] - '9699a524d810d89264bf60d01dab3c751fe47461' + 'cf67ad5622d23845499daf2adba4a11f6b23f9eb' # --- diff --git a/python_modules/dagster-graphql/dagster_graphql_tests/graphql/__snapshots__/test_assets.ambr b/python_modules/dagster-graphql/dagster_graphql_tests/graphql/__snapshots__/test_assets.ambr index e4613783e7ada..49ae424ea0387 100644 --- a/python_modules/dagster-graphql/dagster_graphql_tests/graphql/__snapshots__/test_assets.ambr +++ b/python_modules/dagster-graphql/dagster_graphql_tests/graphql/__snapshots__/test_assets.ambr @@ -117,6 +117,38 @@ ]), }), }), + dict({ + 'id': 'test_location.test_repo.["concurrency_asset"]', + 'key': dict({ + 'path': list([ + 'concurrency_asset', + ]), + }), + }), + dict({ + 'id': 'test_location.test_repo.["concurrency_graph_asset"]', + 'key': dict({ + 'path': list([ + 'concurrency_graph_asset', + ]), + }), + }), + dict({ + 'id': 'test_location.test_repo.["concurrency_multi_asset_1"]', + 'key': dict({ + 'path': list([ + 'concurrency_multi_asset_1', + ]), + }), + }), + dict({ + 'id': 'test_location.test_repo.["concurrency_multi_asset_2"]', + 'key': dict({ + 'path': list([ + 'concurrency_multi_asset_2', + ]), + }), + }), dict({ 'id': 'test_location.test_repo.["diamond_source"]', 'key': dict({ @@ -649,6 +681,26 @@ 'freshnessPolicy': None, 'id': 'test_location.test_repo.["check_in_op_asset"]', }), + dict({ + 'freshnessInfo': None, + 'freshnessPolicy': None, + 'id': 'test_location.test_repo.["concurrency_asset"]', + }), + dict({ + 'freshnessInfo': None, + 'freshnessPolicy': None, + 'id': 'test_location.test_repo.["concurrency_graph_asset"]', + }), + dict({ + 'freshnessInfo': None, + 'freshnessPolicy': None, + 'id': 'test_location.test_repo.["concurrency_multi_asset_1"]', + }), + dict({ + 'freshnessInfo': None, + 'freshnessPolicy': None, + 'id': 'test_location.test_repo.["concurrency_multi_asset_2"]', + }), dict({ 'freshnessInfo': None, 'freshnessPolicy': None, diff --git a/python_modules/dagster-graphql/dagster_graphql_tests/graphql/repo.py b/python_modules/dagster-graphql/dagster_graphql_tests/graphql/repo.py index 01e2923af1089..ff7009136ef72 100644 --- a/python_modules/dagster-graphql/dagster_graphql_tests/graphql/repo.py +++ b/python_modules/dagster-graphql/dagster_graphql_tests/graphql/repo.py @@ -69,6 +69,7 @@ daily_partitioned_config, define_asset_job, graph, + graph_asset, job, logger, multi_asset, @@ -1997,6 +1998,37 @@ def subsettable_checked_multi_asset(context: OpExecutionContext): ) +@asset(pool="foo") +def concurrency_asset(): + pass + + +@op(pool="bar") +def concurrency_op_1(): + pass + + +@op(pool="baz") +def concurrency_op_2(input_1): + return input_1 + + +@graph_asset +def concurrency_graph_asset(): + return concurrency_op_2(concurrency_op_1()) + + +@multi_asset( + specs=[ + AssetSpec("concurrency_multi_asset_1"), + AssetSpec("concurrency_multi_asset_2"), + ], + pool="buzz", +) +def concurrency_multi_asset(): + pass + + # These are defined separately because the dict repo does not handle unresolved asset jobs def define_asset_jobs() -> Sequence[UnresolvedAssetJobDefinition]: return [ @@ -2146,6 +2178,9 @@ def define_assets(): asset_with_compute_storage_kinds, asset_with_automation_condition, asset_with_custom_automation_condition, + concurrency_asset, + concurrency_graph_asset, + concurrency_multi_asset, ] diff --git a/python_modules/dagster-graphql/dagster_graphql_tests/graphql/test_assets.py b/python_modules/dagster-graphql/dagster_graphql_tests/graphql/test_assets.py index 06c3943b75d91..0112913df3a1d 100644 --- a/python_modules/dagster-graphql/dagster_graphql_tests/graphql/test_assets.py +++ b/python_modules/dagster-graphql/dagster_graphql_tests/graphql/test_assets.py @@ -841,6 +841,17 @@ } """ +GET_ASSET_CONCURRENCY_GROUP = """ + query AssetNodeQuery($assetKey: AssetKeyInput!) { + assetNodeOrError(assetKey: $assetKey) { + ...on AssetNode { + id + pools + } + } + } +""" + def _create_run( graphql_context: WorkspaceRequestContext, @@ -3572,3 +3583,17 @@ def test_2d_subset_backcompat(): assert len(ranges[1]["secondaryDim"]["materializedPartitions"]) == 2 assert set(ranges[1]["secondaryDim"]["materializedPartitions"]) == {"a", "c"} assert set(ranges[1]["secondaryDim"]["unmaterializedPartitions"]) == {"b", "d"} + + +def test_concurrency_assets(graphql_context: WorkspaceRequestContext): + def _graphql_pool(asset_key): + result = execute_dagster_graphql( + graphql_context, + GET_ASSET_CONCURRENCY_GROUP, + variables={"assetKey": {"path": asset_key.path}}, + ) + return set(result.data["assetNodeOrError"]["pools"]) + + assert _graphql_pool(AssetKey(["concurrency_asset"])) == {"foo"} + assert _graphql_pool(AssetKey(["concurrency_graph_asset"])) == {"bar", "baz"} + assert _graphql_pool(AssetKey(["concurrency_multi_asset_1"])) == {"buzz"}