add es_host as a parameter to the fastforward task

universalcore · Feb 11, 2015 · 87d81d9 · 87d81d9
1 parent 446e99d
commit 87d81d9
Showing 1 changed file with 3 additions and 2 deletions.
diff --git a/unicore/distribute/tasks.py b/unicore/distribute/tasks.py
@@ -5,8 +5,9 @@
 
 
 @app.task(ignore_result=True)
-def fastforward(repo_path, index_prefix):
-    workspace = EG.workspace(repo_path, index_prefix=index_prefix)
+def fastforward(repo_path, index_prefix, es_host='http://localhost:9200'):
+    workspace = EG.workspace(
+        repo_path, index_prefix=index_prefix, es={'urls': [es_host]})
     workspace.fast_forward()
     workspace.reindex(Page)
     workspace.reindex(Category)