Update settings for queue and syncer
This commit is contained in:
parent
5d2d73fa64
commit
0a5818ebf1
@ -4,6 +4,7 @@ import os
|
|||||||
import uuid
|
import uuid
|
||||||
|
|
||||||
# external imports
|
# external imports
|
||||||
|
from chainlib.settings import ChainSettings
|
||||||
from chainsyncer.settings import ChainsyncerSettings
|
from chainsyncer.settings import ChainsyncerSettings
|
||||||
from chainqueue.settings import ChainqueueSettings
|
from chainqueue.settings import ChainqueueSettings
|
||||||
|
|
||||||
@ -106,18 +107,39 @@ class ChaindSettings(ChainsyncerSettings, ChainqueueSettings):
|
|||||||
raise ValueError('at least one backend must be set')
|
raise ValueError('at least one backend must be set')
|
||||||
|
|
||||||
|
|
||||||
|
def process_chaind_queue(self, config):
|
||||||
|
if config.get('QUEUE_STATE_PATH') == None:
|
||||||
|
queue_state_dir = self.dir_for('queue')
|
||||||
|
config.add(queue_state_dir, 'QUEUE_STATE_PATH', False)
|
||||||
|
logg.debug('setting queue state path {}'.format(queue_state_dir))
|
||||||
|
|
||||||
|
self.process_queue_tx(config)
|
||||||
|
self.process_queue_paths(config)
|
||||||
|
if config.get('QUEUE_BACKEND') == 'fs':
|
||||||
|
self.process_queue_backend_fs(config)
|
||||||
|
self.process_queue_backend(config)
|
||||||
|
self.process_queue_store(config)
|
||||||
|
|
||||||
|
|
||||||
def process(self, config):
|
def process(self, config):
|
||||||
super(ChaindSettings, self).process(config)
|
#super(ChaindSettings, self).process(config)
|
||||||
if self.include_sync:
|
self.process_common(config)
|
||||||
self.process_sync(config)
|
|
||||||
self.process_sync_backend(config)
|
|
||||||
if self.include_queue:
|
if self.include_queue:
|
||||||
self.process_queue_backend(config)
|
self.process_queue_backend(config)
|
||||||
self.process_dispatch(config)
|
if self.include_sync:
|
||||||
self.process_token(config)
|
self.process_sync_backend(config)
|
||||||
|
|
||||||
self.process_backend(config)
|
self.process_backend(config)
|
||||||
self.process_session(config)
|
self.process_session(config)
|
||||||
|
|
||||||
|
if self.include_sync:
|
||||||
|
self.process_sync(config)
|
||||||
|
if self.include_queue:
|
||||||
|
self.process_chaind_queue(config)
|
||||||
|
self.process_dispatch(config)
|
||||||
|
self.process_token(config)
|
||||||
|
|
||||||
self.process_socket(config)
|
self.process_socket(config)
|
||||||
|
|
||||||
|
|
||||||
|
@ -1,6 +1,6 @@
|
|||||||
[metadata]
|
[metadata]
|
||||||
name = chaind
|
name = chaind
|
||||||
version = 0.2.11
|
version = 0.2.12
|
||||||
description = Base package for chain queue service
|
description = Base package for chain queue service
|
||||||
author = Louis Holbrook
|
author = Louis Holbrook
|
||||||
author_email = dev@holbrook.no
|
author_email = dev@holbrook.no
|
||||||
|
Loading…
Reference in New Issue
Block a user