added service mode
This commit is contained in:
parent
3fc93ecb94
commit
17ad4e210d
@ -74,6 +74,15 @@ def setup_logging():
|
|||||||
logger = setup_logging()
|
logger = setup_logging()
|
||||||
|
|
||||||
|
|
||||||
|
def _handle_sigterm(runner):
|
||||||
|
def _h(_sig, _frm):
|
||||||
|
print("SIGTERM received, stopping strategies...")
|
||||||
|
try:
|
||||||
|
runner.stop_all_strategies()
|
||||||
|
finally:
|
||||||
|
sys.exit(0)
|
||||||
|
return _h
|
||||||
|
|
||||||
def main():
|
def main():
|
||||||
"""Main function"""
|
"""Main function"""
|
||||||
print("=" * 60)
|
print("=" * 60)
|
||||||
@ -95,6 +104,14 @@ def main():
|
|||||||
# Create strategy runner
|
# Create strategy runner
|
||||||
runner = MultiStrategyRunner()
|
runner = MultiStrategyRunner()
|
||||||
|
|
||||||
|
if os.getenv("SERVICE_MODE") == "1":
|
||||||
|
print("Starting in SERVICE_MODE (no menu)…")
|
||||||
|
signal.signal(signal.SIGTERM, _handle_sigterm(runner))
|
||||||
|
signal.signal(signal.SIGINT, _handle_sigterm(runner))
|
||||||
|
runner.start_all_strategies()
|
||||||
|
while True:
|
||||||
|
time.sleep(5)
|
||||||
|
|
||||||
# Add debug mode switch
|
# Add debug mode switch
|
||||||
debug_mode = False
|
debug_mode = False
|
||||||
|
|
||||||
|
|||||||
Loading…
x
Reference in New Issue
Block a user