From 8d028adc53244d808425853fd98e0c9bd914fde1 Mon Sep 17 00:00:00 2001 From: Victor Shyba Date: Tue, 9 Feb 2021 19:05:23 -0300 Subject: [PATCH] be a writer by default --- lbry/wallet/orchstr8/node.py | 1 + lbry/wallet/server/db/writer.py | 8 ++++---- 2 files changed, 5 insertions(+), 4 deletions(-) diff --git a/lbry/wallet/orchstr8/node.py b/lbry/wallet/orchstr8/node.py index e70ccab58..be4a4fc7a 100644 --- a/lbry/wallet/orchstr8/node.py +++ b/lbry/wallet/orchstr8/node.py @@ -190,6 +190,7 @@ class SPVNode: 'INDIVIDUAL_TAG_INDEXES': '', 'RPC_PORT': self.rpc_port, 'ES_INDEX_PREFIX': uuid4().hex, + 'ES_MODE': 'writer', } if extraconf: conf.update(extraconf) diff --git a/lbry/wallet/server/db/writer.py b/lbry/wallet/server/db/writer.py index 1ade2cdcb..d2793f77c 100644 --- a/lbry/wallet/server/db/writer.py +++ b/lbry/wallet/server/db/writer.py @@ -951,7 +951,10 @@ class LBRYLevelDB(LevelDB): for algorithm_name in self.env.trending_algorithms: if algorithm_name in TRENDING_ALGORITHMS: trending.append(TRENDING_ALGORITHMS[algorithm_name]) - if self.env.es_mode == 'writer': + if self.env.es_mode == 'reader': + self.logger.info('Index mode: reader') + self.sql = None + else: self.logger.info('Index mode: writer. Using SQLite db to sync ES') self.sql = SQLDB( self, path, @@ -959,9 +962,6 @@ class LBRYLevelDB(LevelDB): self.env.default('FILTERING_CHANNEL_IDS', '').split(' '), trending ) - else: - self.logger.info('Index mode: reader') - self.sql = None # Search index self.search_index = SearchIndex(self.env.es_index_prefix)