Skip to content

Commit 9e70841

Browse files
author
xinshen
committed
Allow to define start worker interval
1 parent 7e918d9 commit 9e70841

File tree

3 files changed

+3
-2
lines changed

3 files changed

+3
-2
lines changed

app/app.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -60,7 +60,7 @@ def main():
6060
worker.daemon = True
6161
worker.start()
6262

63-
time.sleep(60)
63+
time.sleep(settings['start_worker_interval'])
6464
num += 1
6565

6666
logger.info('All workers are running!')

app/conf.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -16,7 +16,7 @@ def __init__(self):
1616
"""
1717

1818
with open('defaults.yml', 'r') as config_file:
19-
default_config = yaml.load(config_file)
19+
default_config = yaml.load(config_file, Loader=yaml.FullLoader)
2020

2121
if os.path.isfile('config.yml'):
2222
with open('config.yml', 'r') as config_file:

app/defaults.yml

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -8,6 +8,7 @@ settings:
88
enable_charts: false
99
output_mode: cli
1010
update_interval: 300
11+
start_worker_interval: 60
1112
market_data_chunk_size: 20
1213
market_pairs: null
1314
timezone: UTC

0 commit comments

Comments
 (0)