Differential D8231 Diff 39295 python_modules/dagster/dagster_tests/core_tests/engine_tests/test_multiprocessing.py
Changeset View
Changeset View
Standalone View
Standalone View
python_modules/dagster/dagster_tests/core_tests/engine_tests/test_multiprocessing.py
| Show First 20 Lines • Show All 151 Lines • ▼ Show 20 Lines | result = execute_pipeline( | ||||
| run_config={"intermediate_storage": {"filesystem": {}}, "execution": {"multiprocess": {}}}, | run_config={"intermediate_storage": {"filesystem": {}}, "execution": {"multiprocess": {}}}, | ||||
| instance=DagsterInstance.ephemeral(), | instance=DagsterInstance.ephemeral(), | ||||
| raise_on_error=False, | raise_on_error=False, | ||||
| ) | ) | ||||
| assert not result.success | assert not result.success | ||||
| assert len(result.event_list) == 1 | assert len(result.event_list) == 1 | ||||
| assert result.event_list[0].is_failure | assert result.event_list[0].is_failure | ||||
| assert ( | assert ( | ||||
| result.event_list[0].pipeline_init_failure_data.error.cls_name | result.event_list[0].pipeline_failure_data.error.cls_name | ||||
| == "DagsterUnmetExecutorRequirementsError" | == "DagsterUnmetExecutorRequirementsError" | ||||
| ) | ) | ||||
| assert "non-ephemeral instance" in result.event_list[0].pipeline_init_failure_data.error.message | assert "non-ephemeral instance" in result.event_list[0].pipeline_failure_data.error.message | ||||
| def test_no_handle(): | def test_no_handle(): | ||||
| result = execute_pipeline( | result = execute_pipeline( | ||||
| define_diamond_pipeline(), | define_diamond_pipeline(), | ||||
| run_config={"intermediate_storage": {"filesystem": {}}, "execution": {"multiprocess": {}}}, | run_config={"intermediate_storage": {"filesystem": {}}, "execution": {"multiprocess": {}}}, | ||||
| instance=DagsterInstance.ephemeral(), | instance=DagsterInstance.ephemeral(), | ||||
| raise_on_error=False, | raise_on_error=False, | ||||
| ) | ) | ||||
| assert not result.success | assert not result.success | ||||
| assert len(result.event_list) == 1 | assert len(result.event_list) == 1 | ||||
| assert result.event_list[0].is_failure | assert result.event_list[0].is_failure | ||||
| assert ( | assert ( | ||||
| result.event_list[0].pipeline_init_failure_data.error.cls_name | result.event_list[0].pipeline_failure_data.error.cls_name | ||||
| == "DagsterUnmetExecutorRequirementsError" | == "DagsterUnmetExecutorRequirementsError" | ||||
| ) | ) | ||||
| assert "is not reconstructable" in result.event_list[0].pipeline_init_failure_data.error.message | assert "is not reconstructable" in result.event_list[0].pipeline_failure_data.error.message | ||||
| def test_solid_selection(): | def test_solid_selection(): | ||||
| with instance_for_test() as instance: | with instance_for_test() as instance: | ||||
| pipe = reconstructable(define_diamond_pipeline) | pipe = reconstructable(define_diamond_pipeline) | ||||
| result = execute_pipeline(pipe, preset="just_adder", instance=instance) | result = execute_pipeline(pipe, preset="just_adder", instance=instance) | ||||
| ▲ Show 20 Lines • Show All 275 Lines • Show Last 20 Lines | |||||