Compare commits
2 Commits
dev-0.2.11
...
v0.1.12
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
0a5818ebf1
|
||
|
|
5d2d73fa64
|
@@ -1,3 +1,6 @@
|
||||
- 0.2.12
|
||||
* Breaking upgrade of chainlib.
|
||||
* Implement generic block and tx.
|
||||
- 0.2.11
|
||||
* Upgrade shep to handle exception in filestore list
|
||||
- 0.2.10
|
||||
|
||||
@@ -4,6 +4,7 @@ import os
|
||||
import uuid
|
||||
|
||||
# external imports
|
||||
from chainlib.settings import ChainSettings
|
||||
from chainsyncer.settings import ChainsyncerSettings
|
||||
from chainqueue.settings import ChainqueueSettings
|
||||
|
||||
@@ -106,18 +107,39 @@ class ChaindSettings(ChainsyncerSettings, ChainqueueSettings):
|
||||
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):
|
||||
super(ChaindSettings, self).process(config)
|
||||
if self.include_sync:
|
||||
self.process_sync(config)
|
||||
self.process_sync_backend(config)
|
||||
#super(ChaindSettings, self).process(config)
|
||||
self.process_common(config)
|
||||
|
||||
if self.include_queue:
|
||||
self.process_queue_backend(config)
|
||||
self.process_dispatch(config)
|
||||
self.process_token(config)
|
||||
if self.include_sync:
|
||||
self.process_sync_backend(config)
|
||||
|
||||
self.process_backend(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)
|
||||
|
||||
|
||||
|
||||
@@ -1,6 +1,6 @@
|
||||
chainlib~=0.1.2
|
||||
chainqueue~=0.1.15
|
||||
chainsyncer~=0.4.7
|
||||
chainlib~=0.2.0
|
||||
chainqueue~=0.1.16
|
||||
chainsyncer~=0.4.9
|
||||
confini~=0.6.0
|
||||
funga~=0.5.2
|
||||
pyxdg~=0.26
|
||||
|
||||
Reference in New Issue
Block a user