safe

Signed-off-by: Dinger <quantdinger@gmail.com>

Author: quantdinger-lab

backend_api_python/app/services/pending_order_worker.py

@@ -707,7 +707,47 @@ def _sync_positions_best_effort(self, target_strategy_id: Optional[int] = None)
                 if to_insert:
                     logger.debug(f"position sync: inserted {len(to_insert)} new positions for strategy_id={sid}")
             except Exception as e:
-                logger.error(f"position sync: strategy_id={sid} failed: {e}", exc_info=True)
+                # Any exchange auth/config/connectivity fatal errors should stop the strategy to avoid endless spam.
+                msg = str(e)
+                m = msg.lower()
+                is_fatal = any(tok in m for tok in (
+                    # Generic HTTP auth / permission failures
+                    " http 401",
+                    "unauthorized",
+                    "forbidden",
+                    "invalid api",
+                    "invalid api-key",
+                    "invalid api key",
+                    "invalid_key",
+                    "invalid key",
+                    "signature mismatch",
+                    "invalid_signature",
+                    "permission",
+                    # Common connection failures (IBKR/TWS, local gateways)
+                    "connection refused",
+                    "connect call failed",
+                    "errno 111",
+                ))
+                if is_fatal:
+                    logger.error(f"[PositionSync] Strategy {sid} fatal error; auto-stopping. error={msg}", exc_info=True)
+                    try:
+                        from app.utils.strategy_runtime_logs import append_strategy_log
+                        append_strategy_log(int(sid), "error", f"Auto-stopped: position sync fatal error: {msg}")
+                    except Exception:
+                        pass
+                    try:
+                        with get_db_connection() as db:
+                            cur = db.cursor()
+                            cur.execute(
+                                "UPDATE qd_strategies_trading SET status = 'stopped' WHERE id = %s AND status = 'running'",
+                                (int(sid),),
+                            )
+                            db.commit()
+                            cur.close()
+                    except Exception:
+                        pass
+                else:
+                    logger.error(f"position sync: strategy_id={sid} failed: {e}", exc_info=True)
 
     def _fetch_pending_orders(self, limit: int = 50) -> List[Dict[str, Any]]:
         try:
@@ -2286,6 +2326,34 @@ def _execute_ibkr_order(
             _console_print(f"[worker] IBKR order exception: strategy_id={strategy_id} pending_id={order_id} err={e}")
             _notify_live_best_effort(status="failed", error=str(e))
             append_strategy_log(strategy_id, "error", f"IBKR order exception ({symbol} {signal_type}): {e}")
+            # Auto-stop strategy on fatal connectivity issues (e.g. TWS/IBG not reachable).
+            try:
+                msg = str(e)
+                m = msg.lower()
+                is_fatal = any(tok in m for tok in (
+                    "connection refused",
+                    "connect call failed",
+                    "errno 111",
+                    "make sure api port on tws",
+                ))
+                if is_fatal:
+                    try:
+                        append_strategy_log(strategy_id, "error", f"Auto-stopped: IBKR connection failed: {msg}")
+                    except Exception:
+                        pass
+                    try:
+                        with get_db_connection() as db:
+                            cur = db.cursor()
+                            cur.execute(
+                                "UPDATE qd_strategies_trading SET status = 'stopped' WHERE id = %s AND status = 'running'",
+                                (int(strategy_id),),
+                            )
+                            db.commit()
+                            cur.close()
+                    except Exception:
+                        pass
+            except Exception:
+                pass
 
     def _execute_mt5_order(
         self,