diff --git a/position_stream.py b/position_stream.py
index debb218..15c04a4 100644
--- a/position_stream.py
+++ b/position_stream.py
@@ -83,7 +83,8 @@ def start_position_worker(
                 payload = refresh_fn()
                 if payload:
                     position_hub.broadcast("positions", payload)
-                connected = bool((payload or {}).get("ctp_status") or {}).get("connected")
+                ctp_st = (payload or {}).get("ctp_status") or {}
+                connected = bool(ctp_st.get("connected"))
                 in_session = bool((payload or {}).get("trading_session"))
                 rows = (payload or {}).get("rows") or []
                 has_sl_tp = any(