Muevo los logs de lugar

datosgobar · Jul 20, 2018 · 1aaeafa · 1aaeafa
1 parent 02741d4
commit 1aaeafa
Show file tree

Hide file tree

Showing 2 changed files with 6 additions and 5 deletions.
diff --git a/series_tiempo_ar_api/apps/metadata/indexer/catalog_metadata_indexer.py b/series_tiempo_ar_api/apps/metadata/indexer/catalog_metadata_indexer.py
@@ -23,13 +23,9 @@ def __init__(self, data_json, catalog_id, task, doc_type=Field):
         self.elastic = ElasticInstance.get()
 
     def index(self):
-        IndexMetadataTask.info(self.task,
-                               u'Inicio de la indexación de metadatos de {}'.format(self.catalog_id))
-
         actions = self.scrap_datajson()
 
         self.index_actions(actions)
-        IndexMetadataTask.info(self.task, u'Fin de la indexación de metadatos de {}'.format(self.catalog_id))
 
     def index_actions(self, actions):
         for success, info in parallel_bulk(self.elastic, actions):

diff --git a/series_tiempo_ar_api/apps/metadata/indexer/metadata_indexer.py b/series_tiempo_ar_api/apps/metadata/indexer/metadata_indexer.py
@@ -32,12 +32,17 @@ def init_index(self):
 
     def run(self):
         self.init_index()
-        IndexMetadataTask.info(self.task, "Inicio la lectura de metadatos")
         for node in Node.objects.filter(indexable=True):
             try:
                 data_json = DataJson(node.catalog_url)
+                IndexMetadataTask.info(self.task,
+                                       u'Inicio de la indexación de metadatos de {}'
+                                           .format(node.catalog_id))
                 CatalogMetadataIndexer(data_json, node.catalog_id, self.task, self.doc_type).index()
                 EnhancedMetaIndexer(node, self.task, self.doc_type).index()
+                IndexMetadataTask.info(self.task, u'Fin de la indexación de metadatos de {}'
+                                           .format(node.catalog_id))
+
             except Exception as e:
                 IndexMetadataTask.info(self.task,
                                        u'Error en la lectura del catálogo {}: {}'.format(node.catalog_id, e))