Differential D5928 Diff 29382 python_modules/dagster/dagster_tests/api_tests/test_api_snapshot_pipeline.py

Changeset View

Standalone View

Show First 20 Lines • Show All 43 Lines • ▼ Show 20 Lines	with get_foo_grpc_pipeline_handle() as pipeline_handle:
assert isinstance(external_pipeline_subset_result, ExternalPipelineSubsetResult)		assert isinstance(external_pipeline_subset_result, ExternalPipelineSubsetResult)
assert external_pipeline_subset_result.success == False		assert external_pipeline_subset_result.success == False
assert (		assert (
"No qualified solids to execute found for solid_selection"		"No qualified solids to execute found for solid_selection"
in external_pipeline_subset_result.error.message		in external_pipeline_subset_result.error.message
)		)


@pytest.mark.skipif(sys.version_info.major < 3, reason="Exception cause only vailable in py3+")
def test_pipeline_with_invalid_definition_snapshot_api_grpc():		def test_pipeline_with_invalid_definition_snapshot_api_grpc():
with get_bar_grpc_repo_handle() as repo_handle:		with get_bar_grpc_repo_handle() as repo_handle:
pipeline_handle = PipelineHandle("bar", repo_handle)		pipeline_handle = PipelineHandle("bar", repo_handle)

external_pipeline_subset_result = _test_pipeline_subset_grpc(		external_pipeline_subset_result = _test_pipeline_subset_grpc(
pipeline_handle, ["fail_subset"]		pipeline_handle, ["fail_subset"]
)		)
assert isinstance(external_pipeline_subset_result, ExternalPipelineSubsetResult)		assert isinstance(external_pipeline_subset_result, ExternalPipelineSubsetResult)
Show All 15 Lines