add index harvest_error_harvest_object_id_idx

ckan · Oct 10, 2022 · 41a620b · 41a620b
1 parent cb0a703
commit 41a620b
Showing 1 changed file with 6 additions and 0 deletions.
diff --git a/ckanext/harvest/model/__init__.py b/ckanext/harvest/model/__init__.py
@@ -97,6 +97,11 @@ def setup():
             log.debug('Creating index for harvest_object_extra')
             Index("harvest_object_id_idx", harvest_object_extra_table.c.harvest_object_id).create()
 
+        index_names = [index['name'] for index in inspector.get_indexes("harvest_object_error")]
+        if "harvest_error_harvest_object_id_idx" not in index_names:
+            log.debug('Creating index for harvest_object_error')
+            Index("harvest_error_harvest_object_id_idx", harvest_object_error_table.c.harvest_object_id).create()
+
 
 class HarvestError(Exception):
     pass
@@ -398,6 +403,7 @@ def define_harvester_tables():
         Column('stage', types.UnicodeText),
         Column('line', types.Integer),
         Column('created', types.DateTime, default=datetime.datetime.utcnow),
+        Index('harvest_error_harvest_object_id_idx', 'harvest_object_id'),
     )
     # Harvest Log table
     harvest_log_table = Table(