From 86e61df99385be7b8de767bd7099fec16f69424b Mon Sep 17 00:00:00 2001
From: dekun <dekun@local>
Date: Thu, 25 Jun 2026 13:52:09 +0800
Subject: [PATCH] =?UTF-8?q?fix:=20=E4=BF=AE=E6=AD=A3=E6=8C=81=E4=BB=93=20w?=
 =?UTF-8?q?orker=20=E4=B8=AD=20bool=20=E4=BC=98=E5=85=88=E7=BA=A7=E5=AF=BC?=
 =?UTF-8?q?=E8=87=B4=20.get=20=E6=8A=A5=E9=94=99=E3=80=82?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

Co-authored-by: Cursor <cursoragent@cursor.com>
---
 position_stream.py | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)

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(