diff --git a/start.sh b/start.sh index 303fada..59f3e59 100644 --- a/start.sh +++ b/start.sh @@ -1,6 +1,9 @@ #!/bin/sh # Запуск шедулера +dask-scheduler - -# Запуск воркеров \ No newline at end of file +# Запуск воркеров +PYTHONPATH=. dask-worker 127.0.0.1:8786 & +PYTHONPATH=. dask-worker 127.0.0.1:8786 & +PYTHONPATH=. dask-worker 127.0.0.1:8786 & diff --git a/starter.py b/starter.py index 09972ce..bb3e74b 100644 --- a/starter.py +++ b/starter.py @@ -98,7 +98,7 @@ def start_futures(): data = client.map(load_data, isins) params_a = client.map(get_param, data, ['param_a'] * len(isins)) - params_b = client.map(get_param, data, ['param_a'] * len(isins)) + params_b = client.map(get_param, data, ['param_b'] * len(isins)) result_a = client.map(task_a, isins, params_a, params_b)