starter

vmarunov · Jun 28, 2018 · 7ee342e · 7ee342e
1 parent 70ad519
commit 7ee342e
Show file tree

Hide file tree

Showing 2 changed files with 6 additions and 3 deletions.
diff --git a/start.sh b/start.sh
@@ -1,6 +1,9 @@
 #!/bin/sh
 
 # Запуск шедулера
+dask-scheduler
 
-
-# Запуск воркеров
+# Запуск воркеров
+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
@@ -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)