Merge pull request #109 from collective/queue_processor_active

Check addon is installed before processing queue

CHANGELOG.md

@@ -16,8 +16,11 @@
 
 - Handle negative term filters (fixes #101) @instification
 
+- Check addon is installed before processing queue (fixes #108) @instification
+
 - Add support for optional es host in worker via PLONE_ELASTICSEARCH_HOST env variable @maethu
 
+
 ## 5.0.0 (2022-10-11)
 
 - Rename `master` branch to `main` @ericof

src/collective/elasticsearch/queueprocessor.py

@@ -123,6 +123,8 @@ def _uuid_path(self, obj):
 
     def index(self, obj, attributes=None):
         """Index the specified attributes for an obj."""
+        if not self.manager.active:
+            return
         actions = self.actions
         uuid, path = self._uuid_path(obj)
         actions.uuid_path[uuid] = path
@@ -156,10 +158,14 @@ def index(self, obj, attributes=None):
 
     def reindex(self, obj, attributes=None, update_metadata=False):
         """Reindex the specified attributes for an obj."""
+        if not self.manager.active:
+            return
         self.index(obj, attributes)
 
     def unindex(self, obj):
         """Unindex the obj."""
+        if not self.manager.active:
+            return
         actions = self.actions
         uuid, path = self._uuid_path(obj)
         actions.uuid_path[uuid] = path