diff --git a/entities.py b/entities.py index 418cc00ec3e8e9d151e66663e976d1fd20e436d5_ZW50aXRpZXMucHk=..ac5f8d85cf00f9cbc9a6b544b75d4161182c1a9d_ZW50aXRpZXMucHk= 100644 --- a/entities.py +++ b/entities.py @@ -60,8 +60,12 @@ } } + @property + def index_name(self): + return self._cw.vreg.config['index-name'] + def get_connection(self): self.create_index() return es.get_connection(self._cw.vreg.config) def create_index(self, index_name=None, custom_settings=None): @@ -63,9 +67,9 @@ def get_connection(self): self.create_index() return es.get_connection(self._cw.vreg.config) def create_index(self, index_name=None, custom_settings=None): - index_name = index_name or self._cw.vreg.config['index-name'] + index_name = index_name or self.index_name if custom_settings is None: settings = self.settings else: diff --git a/hooks.py b/hooks.py index 418cc00ec3e8e9d151e66663e976d1fd20e436d5_aG9va3MucHk=..ac5f8d85cf00f9cbc9a6b544b75d4161182c1a9d_aG9va3MucHk= 100644 --- a/hooks.py +++ b/hooks.py @@ -66,7 +66,7 @@ json = serializer.serialize() try: # TODO option pour coté async ? thread - kwargs = dict(index=self.cnx.vreg.config['index-name'], + kwargs = dict(index=indexer.index_name, id=entity.eid, doc_type=entity.cw_etype, body=json)