quantfortune/SIP_GoldBees_Backend
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Improve resume strategy error handling and status updates

Browse Source
This commit is contained in:
Thigazhezhilan J 2026-03-28 13:45:51 +05:30
parent 79c036ca8b
commit 382b5aa5f6
1 changed files with 16 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

25
backend/app/services/strategy_service.py
View File

@ -611,20 +611,27 @@ def resume_strategy(user_id: str):
"broker": broker_state.get("broker"), "broker": broker_state.get("broker"),
} }
if not engine_external:
engine_config = _build_engine_config(user_id, run_id, None)
if not engine_config:
return {
"status": "resume_failed",
"run_id": run_id,
"message": "Saved strategy configuration is incomplete.",
}
started = start_engine(engine_config)
if not started:
return {
"status": "resume_failed",
"run_id": run_id,
"message": "Strategy engine could not be started.",
}
reactivate_strategy_config(user_id, run_id) reactivate_strategy_config(user_id, run_id)
resume_run(user_id, run_id) resume_run(user_id, run_id)
_write_status(user_id, run_id, "RUNNING") _write_status(user_id, run_id, "RUNNING")
update_run_status(user_id, run_id, "RUNNING", meta={"reason": "user_resume"}) update_run_status(user_id, run_id, "RUNNING", meta={"reason": "user_resume"})
if not engine_external:
engine_config = _build_engine_config(user_id, run_id, None)
if not engine_config:
return {"status": "resume_failed", "run_id": run_id}
started = start_engine(engine_config)
if not started:
return {"status": "resume_failed", "run_id": run_id}
_write_status(user_id, run_id, "RUNNING")
try: try:
user = get_user_by_id(user_id) user = get_user_by_id(user_id)
if user: if user: