feat: re-enable auto-run pipeline after connectivity test
This commit is contained in:
15
main.py
15
main.py
@@ -728,9 +728,22 @@ def main():
|
|||||||
log(f"[ModelHub提交] ❌ error={e}")
|
log(f"[ModelHub提交] ❌ error={e}")
|
||||||
|
|
||||||
log("=" * 50)
|
log("=" * 50)
|
||||||
log("连通性测试完成,请查看上方结果")
|
log("连通性测试完成")
|
||||||
log("=" * 50)
|
log("=" * 50)
|
||||||
|
|
||||||
|
# 开始正式提交流程
|
||||||
|
log("\n自动触发提交流程...")
|
||||||
|
try:
|
||||||
|
state['running'] = True
|
||||||
|
state['last_run'] = datetime.now().isoformat()
|
||||||
|
count = run_pipeline(submit_limit=30)
|
||||||
|
state['last_result'] = {'submitted': count, 'success': True}
|
||||||
|
except Exception as e:
|
||||||
|
log(f"流程异常: {traceback.format_exc()}")
|
||||||
|
state['last_result'] = {'error': str(e), 'success': False}
|
||||||
|
finally:
|
||||||
|
state['running'] = False
|
||||||
|
|
||||||
threading.Thread(target=_startup_test, daemon=True).start()
|
threading.Thread(target=_startup_test, daemon=True).start()
|
||||||
|
|
||||||
while not shutdown_requested:
|
while not shutdown_requested:
|
||||||
|
|||||||
Reference in New Issue
Block a user