Differential D4920 Diff 24623 python_modules/libraries/dagster-dask/dagster_dask_tests/test_resources.py
Changeset View
Changeset View
Standalone View
Standalone View
python_modules/libraries/dagster-dask/dagster_dask_tests/test_resources.py
| Show All 24 Lines | with context.resources.dask.client.as_current(): | ||||
| client = Client.current() | client = Client.current() | ||||
| yield Output(client.scheduler_info(), "scheduler_info") | yield Output(client.scheduler_info(), "scheduler_info") | ||||
| yield Output(client.nthreads(), "nthreads") | yield Output(client.nthreads(), "nthreads") | ||||
| @pipeline(mode_defs=[ModeDefinition(resource_defs={"dask": dask_resource})]) | @pipeline(mode_defs=[ModeDefinition(resource_defs={"dask": dask_resource})]) | ||||
| def scheduler_info_pipeline(): | def scheduler_info_pipeline(): | ||||
| return scheduler_info_solid() | scheduler_info_solid() | ||||
| def test_single_local_cluster(): | def test_single_local_cluster(): | ||||
| cluster_config = { | cluster_config = { | ||||
| "n_workers": 2, | "n_workers": 2, | ||||
| "threads_per_worker": 1, | "threads_per_worker": 1, | ||||
| "dashboard_address": None, | "dashboard_address": None, | ||||
| } | } | ||||
| Show All 30 Lines | |||||