es fixes

2012-05-10 17:10:01 -04:00 · 2012-05-10 17:10:01 -04:00 · ec9b19d77f
commit ec9b19d77f
parent 0cddf437fb
1 changed files with 4 additions and 5 deletions
--- a/oyster/ext/elasticsearch.py
+++ b/oyster/ext/elasticsearch.py
@ -17,8 +17,7 @@ class ElasticSearchPush(Task):

        self.get_logger().debug('adding {0} to ElasticSearch'.format(doc_id))

-        for i, piece in enumerate(pieces):
-            es.index(dict(doc['metadata'], text=text),
-                     settings.ELASTICSEARCH_INDEX,
-                     settings.ELASTICSEARCH_DOC_TYPE,
-                     id=doc_id)
+        es.index(dict(doc['metadata'], text=text),
+                 settings.ELASTICSEARCH_INDEX,
+                 settings.ELASTICSEARCH_DOC_TYPE,
+                 id=doc_id)