+
~_j}} R t ^ RIt^ RIt^ RIt^ RIt^ RIt^ RIt^ RIt^ RI t^ RI
H t ^ RI H t H
t
HtHt ^ RIt^ RIt^ RIt] ! ]4 P- 4 P. ^, t]! ]R, 4 ]P4 9 d* ]P4 P7 ^ ]! ]R, 4 4 R/ RRbRRbR R
bR ^4bR R
bRRbRRbR^bR^bR^, R?R@7 .RA7 ]PP ! ])4 t*]PV ! RBRC4 t,]PV ! RDRE4 t-Rs.RF t/RG t0RH t1RI t2]PV ! RJRK4 t3Rs4/ t5RL t6RM t7RN t8RO t9RRP lt:RQ t;RRR RS llt
────────────────
Your private link:
u
This link is personal to you. Do not share it — if it leaks, /requestdashboard again and I can issue a new one.uU 📺 DASHBOARD REQUEST
────────────────
From: u[
────────────────
To approve: /grantdashboard uO ✅ Dashboard access request sent to the owner.
You'll be notified if approved.z/grantdashboardzAdmin command only.z:Usage: /grantdashboard <chat_id> [name]F)r uo 🎉 Dashboard access granted
────────────────
Your private link:
u# ✅ Dashboard access granted to z
Token: zz/revokedashboardz4Usage: /revokedashboard <chat_id>u' ✅ Dashboard access revoked for u* ⚠️ No dashboard token found for z/listdashboardz No dashboard tokens granted.u 📺 Dashboard access0 ────────────────r z (admin)u • z (no name)z
ID: rH z
Granted: r N
N
z/leaver5 r6 rG uQ 👋 You've been removed from the alert list.
Use /requestaccess to rejoin later.u ℹ️ z (z ) left the alert list.zLeave command failed: z=Admin cannot /leave. Edit TELEGRAM_CHAT_ID env var if needed.z'You're not currently on the alert list./add/remove/list/pending
/announcementuF 🚫 That command is admin-only.
Use /requestaccess to request access.zNo recipients configured.u 👥 ACTIVE RECIPIENTSu 👑 ADMINadded_at · u
· added zTotal: u 📭 No pending access requests.u 📥 PENDING REQUESTS:N NTu · z Approve: /add zYUsage: /add <chat_id> [name]
Example: /add 987654321 Johnc 3 ^ <" T F" p\ VP R 4 4 S8H x K$ R# 5ir r )r r] new_ids & rC r r s$ EHq3quuY'(F2Hs *-Tu
ℹ️ z is already on the list.added_byu ✅ Added ()z to the alert list.u9 🎉 You're in!
────────────────
The owner has granted you access to the macro model alerts. You'll start receiving them on the next signal check.
Commands:
/help — show commands & disclaimer
/whoami — your chat ID
/leave — stop receiving alerts
────────────────
⚠️ DISCLAIMER
This bot is provided for educational and informational purposes only. Alerts do not constitute financial advice or a recommendation to buy or sell any security. Past backtest performance is not indicative of future results. Systematic trading involves substantial risk of loss. You are solely responsible for your own trading decisions. By using this bot you acknowledge and accept these terms. Type /help to see the full disclaimer.u ❌ Add failed: z+Usage: /remove <chat_id>u% 🚫 Cannot remove the admin chat ID.z is not on the list.u ✅ Removed z from the alert list.ua 👋 You've been removed from the macro model alerts.
Use /requestaccess if you'd like to rejoin.u ❌ Remove failed: zUsage: /announcement <your message>
Example: /announcement Model paused for 30 min for maintenance
Message must be at least 5 characters.zNo recipients to send to.uU 📣 ANNOUNCEMENT FROM ADMIN
────────────────
u 📢 Broadcasting to z recipient(s)...u ✅ Announcement sent to all z recipients.u ⚠️ Announcement sent to /z recipients.
u3 delivery failure(s) — check log for details.zAnnouncement broadcast: z
success, z fail | text: :NP NzUnknown command: z
Type /help for options.)z/startz/help)r r r r r )&rK rL lowerrt r r` r rf rg _pending_access_requestsrJ r< nextr{ ru _pending_dashboard_requestsr joinrR r popr r rD rN rO rP rQ rq rT rU rV itemsrl anyr info
startswith))rH r r r partscmdargsr display_namein_list
disclaimeradmin_idexistingr target_idr r rz linesr admin_tagrG r\ r. r] r_ richr^ r addedlinereq_cidwhenrm_idbeforeafter message_text broadcastr r r s) f&&& @rC r r s
:: % '"") +**1!L> B( ) #
. Y
!! >$:$< >?CE '(hw.?-@AC VW "
L HLLN 4 4 60
#G, '(..s3A6<<> % '"") +55*?7*J '(a1K &L\" l!34 : %Y /066s;A>DDF!!, xy@]^"* Y$+9
.
Cwi X GG 8!
g~%'
')DCG;;==4::dnngn >?WcegVhD6:hh|R6PQ6PCi()1,6PDQ 5 J 56hiE!-6s^^M xxR(xx+9=*9M9MR05SU uG,4v .$Jug"66$ ! T" "
LLK L LL73z?"34 5 $))E*gY ?
j'' <y Q 45ghE!9!?!?!A
xx+xx3C8@@cJ vgYk$tD6 JK 5gYavW MN "B
$))E*gY ?
f} <!
a %(Y]sxxR!- F')DCG;;==4::dnngn >?WcegVhDxx b1HsEHEsssEHEEE
fX5T Uah`ijF&> >/7;;FBG OO6HLLN 4 4 6G
X & $ ( ( 6 "6('2d4&lPRSVkk!
M$ !'
.
i =!
Q
U AWI V I')DCG;;==4::dnngn >?WcegVhD,34F-1XXlB-G "F-G&)!%% *:&;u&D #$!-G "FD \*+E
eW4O P\c[de T, / 0 .ug5QR^e]f g >
o CHI,,. | q 9 "
%'
5 J An
&s:&77K L Y
39jI
19 27);KL!
1'!GdN;K LVNP!
+G9JtfNS_`cSdRefg s)#.GHT[S\] e&L
: 4QC 899
:0 R D p F ,QC0G9 E E F&"F I /s3wi H H Is A u '!u
u A6u %A u; $u6'u; A&v (v ? v v 1v 9B?v A9v> !v92v981v> +2v> u u3u..u36u; ;
v v v6v11v69v> > w% w w%c " R RRRRRRRRRRRRR/# )
position_openFposition_ticketNposition_signal entry_price
entry_time position_lot last_zscorerA rA rB rC _blank_stater n s/ 5444444 rB c
R RRRRRRRRR/# )activeF directionN target_price
armed_time
zscore_absrA rA rB rC _blank_armedr' y s% rB r c @ \ \ V , R , , # )r& )r@ PAIR_CONFIGpairs &rC _state_pathr, s [&|4 44rB c
\ \ V , 4 pVP R 4 ' d VR , P 4 VR & VP R4 ' d8 \ VR, \
4 ' g VR, P 4 VR& \ \ V , 4 pVP R4 ' d VR, P 4 VR& W!R& \ V 4 pVP R4 pVP \ P ! V^R7 RR7 ^ RI pVP \ V4 \ V4 4 R# \ d' p\ P! R T R
T 24 Rp?R# Rp?ii ; i) r cooldown_untilr% _armedrc rd r5 r6 N[z] State save failed: )dict
PAIR_STATErR rg r rJ
PAIR_ARMEDr, rh ri rO rj rk rl rT rU rV )r+ r. armedtargetro rp r_ s & rC
save_stater6 s2 8Jt$% 88L ! !!%l!3!=!=!?D 88$ % %j>N9OQT.U.U%)*:%;%E%E%GD! "Z%& 99\ " ""' "5"?"?"AE, X T" ( tzz$q1GD CHc&k* 8 av 21#6778s A E C/E F E==Fc \ V 4 pVP 4 ' g R # \ P ! VP RR7 4 pVP R4 ' d- \ P ! VR, 4 \ V , R& VP R4 ' d R F" pVP V4 \ V , V& K$ VP R4 ' d, \ P ! VR, 4 \ V , R& \ P RV R \ V , R, 24 \ R
V R \ V , R, R \ V , R, R
24 VP R/ 4 pVP R4 ' Ed VP R4 pV' Ed \ P ! V4 p\ P ! 4 V,
P 4 R, pVR8 d R\ V , R& VP R4 \ V , R& VP R4 \ V , R& V\ V , R& VP R4 \ V , R& \! RV,
^4 p\ P RV RVR
R24 R # R # R # R # \ d EL[zG] STATE RESTORED AFTER REBOOT
Position was open at restart
Ticket: z
Entry: z
Resuming monitoring...r/ r" r% @Tr# r$ r& u ] Armed signal restored — .1fz h remainingz] State restore failed: )r r r r r r )r, rN rO rP rQ rR r
fromisoformatr2 rT rU r r utcnow
total_secondsr3 roundrV )
r+ pr. k
armed_dataat_strr% hours_since remainingr_ s
& rC
load_staterE s DA 88::*;
zz!++{+;< 88$ % %
5=5K5K)*6,
4 !12 88O $ $B&*hhqk
4 #B xx %%191G1G\HZ1[
4 . HHq ::d;KL];^:_` a dV $%d+,=>? @$T*=9: ;)*
XXh+
>>( # # ^^L1Fv % 3 3F ;
' 0: = L L NQU U $7;Jt$X.7A~~k7RJt$[17A~~n7UJt$^47AJt$\27A~~l7SJt$\2 %cK&7 ;IHHq&B9S/Q\ ]^ % $#
< ; av 5aS9::;sU K $B:K K 9C;K < K K
K K K?K::K?c | \ P ! 4 p \ R , V 8X d \ P R4 R# ^ RIHp \ P R4 V! 4 pV \ R & \ P R4 V# \ d h \ d$ p\ P RT 24 Rp?R# Rp?ii ; i) r u, Rate data already updated today — skippingT)update_all_ratesz+Updating rate data (FinanceFlow primary)...z-Rate data updated successfully (US + DE + JP)zRate update failed: NF)
r todayLAST_RATE_UPDATErU r ingestion.auto_rates_loaderrG KeyboardInterruptrT error)rH rG r r_ s rC update_rate_datarM s JJLE 5( ?@
@ >?
#( @A
(,-s AB B;B;B66B;c ^ RI p \ R, p RpV P 4 pRVn V P Vn \ P P VRR/R7 p\ P P V^ VR7 ;_uu_ 4 pVP 4 P R R
R 7 pRRR4 XP 4 Uu. uF5 qwP 4 ' g K VP R 4 ' d K3 VNK7 pp. p VR
, F p
V
P R4 U u. uF qP 4 NK p p \! V 4 ^8 d KB \" P$ ! V ^ , RR7 p
\' V ^, 4 pV P) RV
P+ R4 RV/4 K V ' dl \" P0 ! V 4 P3 R4 P5 R4 pVP7 VRR7 \8 P; R\! V4 R24 R# R# + ' g i EL|; iu upi u up i \, \. 3 d EKD i ; i \< d$ p\8 P? RT 24 Rp?R# Rp?ii ; i)u
Basic JP2Y fallback — used only if fetch_jp2y_robust.py is not deployed.
Prefer fetch_jp2y_robust.update_jp2y_if_stale() which has all EU bugs fixed.
Nr+ z[https://www.mof.go.jp/english/policy/jgbs/reference/interest_rate/historical/jgbcme_all.csvFz
User-Agentz Mozilla/5.0)headersr r5 rl errors#r rF z%Y/%m/%d)r9 r %Y-%m-%djp2yindexzJP2Y updated: u rows → jp2y.csvz#JP2Y update failed (using cached): ) r RATES_DIRr r r r r r r r r r
splitlinesrK r rL r pd to_datetimefloatr strftime
ValueError
IndexError DataFramedrop_duplicates sort_valuesto_csvrU r rT rV )r jp2y_pathr r r r r/ lr rowsr r? r dtvaldfr_ s rC _update_jp2y_basicri s
J&I?k((* " --~~%%cL-3P%Q
^^
#
#CS
#
A
AT))+$$WY$?C B NN ,T ,q !,,sBS ,T"IID(,
381WWYE85zA~
nnU1XjAE!Ho VR[[%>?s A7I
"H ,I H3"H3;H3#I $H8<I AH=& I 2A)I H0 *I =II II J!I??Jc ^ RI p\ R, R, R, R, R, pVP P RRR7 VP RVP
^ V 4 pVe \
V4 ^ 8X d* \ P R VP 4 R
24 R # \ P ! V4 p\ P ! VR , R
RR7 P P R4 VR& VP RR/R7 pV. RO, P! R4 pVP# VR R7 R# \$ d$ p\ P RT 24 Rp?R # Rp?ii ; i)u Refresh EURUSD_1H_recent.csv with fresh bars from MT5.
Used by get_bars_1h for EURUSD. Failure to refresh is non-fatal — caller
will still read whatever's in the CSV from the last successful refresh.
Matches the format produced by src/research/export_recent_bars.py exactly.
Nr. r/ pricesr EURUSD_1H_recent.csvTr2 z3[EURUSD] recent CSV refresh: MT5 returned no bars (r Ftimes)unitutcr tick_volumevolumecolumnsrU z0[EURUSD] recent CSV refresh failed (non-fatal): )r openhighlowcloserr ) MetaTrader5 BASE_PATHparentmkdircopy_rates_from_pos TIMEFRAME_H1r rU rV
last_errorrY r_ rZ rf tz_localizerenamera rb rT )n_barsmt5out_pathr0 rh r_ s & rC _refresh_eurusd_recent_csvr s, ! v%-88CF\\ dT :''#2B2BAvN =CJ!O KKMcnnN^M__`a b
\\%
6
$GJJVVW[\:
YY
x 8Y
9
A
B
N
Nz
Z
(% ( FqcJKs B#D< 'BD< < E*E%%E*c 4 \ R, R, R, R, p V R, pV R, p. ROp. pW3 EF pVP 4 ' g K \ P ! V4 pVP Uu. uF qwP 4 P
4 NK" upVn RpV F p WP 9 g K T p M Vf< \ P R VP R
\ VP 4 R 24 K \ P ! Wh, R R
R7 VR& \ P ! VR, R
R7 VR& VP RR.R7 pRR.p
R FF p WP 9 g K \ P ! Wk, R
R7 Wk& V
P V 4 KH VP Wj, 4 EK V' g R# \ P ! VRR7 P# R.RR7 P% R4 P' RR7 p
V
# u upi \ d2 p \ P RTP RT 24 Rp ? EK" Rp ? ii ; i \ d$ p \ P) RT 24 Rp ? R# Rp ? ii ; i) uA Load the canonical 1H EURUSD price history (2003 → today).
Combines:
EURUSD_1H_2003_2026.csv (full historical archive — 'Time (EET)' column,
'YYYY.MM.DD HH:MM:SS' format, 142k+ bars)
EURUSD_1H_recent.csv (rolling window kept fresh by MT5 — 'datetime'
column, ISO format, ~5k bars)
Both files are treated as EET (validated convention — matches the trading
session filter and the original backtest). No timezone conversion.
Returns None if neither file is readable — caller should fall back to MT5.
r. r/ rk r zEURUSD_1H_2003_2026.csvrl r Nz [EURUSD] z#: no timestamp column found (have: r mixedcoerce)r9 rQ rx rP subsetz[EURUSD] could not read : T) ignore_indexlast)r keepdropz-[EURUSD] _load_eurusd_canonical_bars failed: )r r rm timestampz
time (eet)z time(eet)time_eetztime eet)ru rv rw rr )rz rN rY read_csvrt rK r rU rV r r rZ
to_numericdropnar rT concatr` ra reset_indexrL ) price_dirarchiverecentTIMESTAMP_COL_CANDIDATESframesr\ rh rY dt_colcandcolsoptr_ combineds rC _load_eurusd_canonical_barsr s9 ; &.9HD 99 66$
%D;;==
[[&9; DAggioo / D
4Dzz)!% 5 >KK)DII; 7**.rzz*:);1!> ? "$
7S[!\:!# r'{8!L7 YYz'&:Y; #G, =CJ!O II&!3CNN4D3EF G
\\%
6
=:HIPP"H- Q //:{:/F{{X\{G] ^ Z KKTUVTWX Y Y Z AfX 21#67s> AE %E ;A F A3F E> E99E> F2 F--F2c ^ RI pVP pVP W^ V4 pVe \ V4 ^ 8X d, \ P RV RVP
4 24 R# \ P ! V4 p\ P ! VR, RR7 VR& V. R O, P R4 P RR 7 # \ d' p\ P RT R
T 24 Rp?R# Rp?ii ; i) r Nr0 z] 15M bars failed: rm rn r r Tr z] get_bars_15m error: )r ru rv rw rx )
ry
TIMEFRAME_M15r} r rU rL r rY r_ rZ ra r rT )r r r r r0 rh r_ s && rC get_bars_15mr s
!
''Av> =CJ!O II&!4S^^5E4FG H
\\%
6
=::;GG # . / AfX 3A378s A C $A!C C7C22C7c ^ RI pVP V 4 pV' d VP VP 3# R# \ d' p\
P
RT RT 24 Rp?R# Rp?ii ; i)r Nr0 z] get_live_price error: )ry symbol_info_tickbidaskrT rU rL )r r tickr_ s & rC get_live_pricer sa !##F+'+$((#55 AfX 5aS9:s 9 9 9 A*A%%A*c \ V , pVR, R8X d \ W4 # VR, R8X d \ W4 # \ W4 # )zDispatch to correct z-score engine per pair.
`prices_df` is 15M bars for EURUSD (beta_model_15m), 1H bars for USDJPY (spread_zscore).
r" r#
beta_model)r) _compute_eurusd_zscore_15m_compute_eurusd_zscore_compute_spread_zscore)r+ prices_dfcfgs && rC compute_zscorer sJ
d
C
= --))99 ] | +%i55%i55rB c *
a ^ RI Hp V P 4 p V R, P P 4 V R& V P RRR7 P
R0R7 P R4 P RR 7 pVR, P 4 VR
& \ P ! VR, 4 VR& R pV! R R
4 pV! RR4 pV! RR4 pV! RR4 p\ P ! R\ P ! VR, P 4 VR, P 4 RR7 /4 oV3R lp V ! VR
4 P! V ! VR4 RR7 P! V ! VR4 RR7 P! V ! VR4 RR7 p
V
R
, V
R, ,
V
R& V
R, V
R, ,
V
R& V
R, P# ^4 V
R& V
R, P# ^4 V
R& V
. R1O, P% 4 p
VP! V
RR R 7 P% R
R.R 7 p \' V 4 p V \( ^, 8 Ed \* P- R V 24 T p
\. P0 ! V
\. P2 4 p\. P0 ! V
\. P2 4 p\5 \( V
4 EF pV P6 V\( ,
V P 4 pVVR, P9 4 ^ 8 VR, P9 4 ^ 8 , , p\' V4 ^ 8 d K~ VP; VRR., 4 p VP= VR
, V4 P? 4 pVP@ PC R\. P2 4 VV& VP@ PC R\. P2 4 VV& EK \ PF ! V4 PI \J R 7 PM 4 PO ^4 PQ R2R!4 PR V R"& \ PF ! V4 PI \J R 7 PM 4 PO ^4 PQ R3R#4 PR V R$& V R", V R, , V R$, V R, , , V R%& M:\* PU R&V R'\( ^, R(24 V R, R4, V R%& V . R5O, p V P! V RR R 7 pV. R6O, PW 4 V. R6O& VPC R)^4 pVR, P V4 VR*& VR%, VR*, ,
VR+& VR,, pVR+, PY VVR-7 PM 4 pVR+, PY VVR-7 P[ 4 pVR+, V,
V, VR.& VP% R..R 7 P RR 7 # \D d EK i ; i \D d8 p\* P] R/T 24 ^ RI/pTPa 4 Rp?R# Rp?ii ; i)7u% EURUSD VALIDATED FORMULA (v3 — Formula A):
Z-score computed on 15M bars matching backtest exactly:
- lag_gap = predicted_return_1d (daily, OLS) - eurusd_return_24bar (15M pct_change)
- eurusd_return_24bar = 24 × 15M bars = 6-HOUR rolling return
- z-score normalisation: rolling(60) on 15M = 15-HOUR window
- Signal evaluation: every 15M bar
The daily predicted_return_1d series comes from the same rolling-OLS beta
model as v2 (120-day window, 20-day EWM smooth, ±clip, shift 1). It's
forward-filled onto every 15M bar within its day.
Nr r Fas_indexrx rx Tr eurusd_return_1dc D \ V , p\ P ! VR .R7 pVP Uu. uF qDP 4 NK upVn \ P
! W1, RR7 W1& VR V., P
4 P R 4 # u upi r ) parse_datesr rP rW rY r rt r r r ra fnamecolr\ rh rY s && rC load_rate-_compute_eurusd_zscore_15m..load_rate x u$D;;t&:B-/ZZ8Z'')Z8BJmmBGH=BGvsm$++-99&A A 9 B r us2y us10y.csvus10yde2y.csvde2y de10y.csvde10yDfreqc < SP 4 P R R/4 pV P 4 P R R/4 p\ P ! W#R RR7 # r datetime64[us]backward)onr# copyastyperY
merge_asofrate_dfr leftright
date_ranges && rC ffill)_compute_eurusd_zscore_15m..ffill O OO%,,f6F-GHDLLN))63C*DEE==:N NrB r spread_2y
spread_10yspread_2y_change_1dspread_10y_change_1dr r howr z:[EURUSD/15m] z-score path: OLS (full model) | daily bars: span皙?beta_2y{Gz?beta_10ypredicted_return_1dzD[EURUSD/15m] z-score path: FALLBACK (hardcoded -0.03) | daily bars: (need +)r eurusd_return_24bar
lag_gap_24barr min_periodszscorez[EURUSD/15m] zscore error: rx r r r r 皙{Gz Qr r r r r r r 1statsmodels.apiapir rf normalizegroupbyaggra r
pct_changerY rZ r_ r minr mergediffr r BETA_WINDOWrU r npfullnanrangeilocabs add_constantOLSfitr rR rT Seriesewm SMOOTH_SPANmeanshiftclipvaluesrV r rollingstdrL traceback print_exc)
prices_15mr smdaily_pxr r r r r r spreadsmodel_dfn_dailynb2y_rawb10y_rawisampleXresrh lookbackwr r r_ r r s && @rC r r s O$ __&
'
3 6 6 @ @ B
6 &&v&>S 0S1 [($)? (0'8'C'C'E#$ >>(6*:; B *v.+w/*v.+w/\\62== V "HV$4$8$8$:,F #G H
O V$**5w+?6*JE%V,E7eE'>RV\8] '76? B ' 0773C C *1+*>*C*CA*F%&*1,*?*D*DQ*G&'OPWWY>>'f&>AHH&'<= I ?h- kAo % HHQRYQZ[ \Agga(GRWWQ5G(;*! q}Q7<<> (=!>!B!B!Dq!H"()?"@"D"D"F"J!L Mv;#XOOF,ABX+Y$Z[' &&(:!;Q?CCEC"%**..1F"PGAJ"%**..1G"PHQK + $&99W#5#9#9{#9#K#P#P#R#X#XYZ#[#`#`afgk#l#s#sHY #%99X#6#:#: #:#L#Q#Q#S#Y#YZ[#\#a#abghl#m#t#tHZ #x0E'FF$x0F'GGH
* +
KK^_f^ggnoz}~o~n @B C
D.67L.MPU.UH* + gh
h6v
> S T Z Z \ OP 77,b1$&wK$:$:8$D !$&'<$=CX@Y$Y?:/"**1!*<AAC/"**1!*<@@B?+d2c98 yy
y+77T7BB3 !&$&4 /s34)--/s> M Y $BX=%IY = Y
Y Y
Y Z,Z
Zc
a ^ RI Hp V P 4 p V R, P P 4 V R& V P RRR7 P
R/R7 P R4 P RR 7 pVR, P 4 VR
& \ P ! VR, 4 VR& R pV! R R
4 pV! RR4 pV! RR4 pV! RR4 p\ P ! R\ P ! VR, P 4 VR, P 4 RR7 /4 oV3R lp V ! VR
4 P! V ! VR4 RR7 P! V ! VR4 RR7 P! V ! VR4 RR7 p
V
R
, V
R, ,
V
R& V
R, V
R, ,
V
R& V
R, P# ^4 V
R& V
R, P# ^4 V
R& V
. R0O, P% 4 p
VP! V
RR R 7 P% R
R.R 7 p \' V 4 p V \( ^, 8 Ed \* P- R V 24 T p
\. P0 ! V
\. P2 4 p\. P0 ! V
\. P2 4 p\5 \( V
4 EF pV P6 V\( ,
V P 4 pVVR, P9 4 ^ 8 VR, P9 4 ^ 8 , , p\' V4 ^ 8 d K~ VP; VRR., 4 p VP= VR
, V4 P? 4 pVP@ PC R\. P2 4 VV& VP@ PC R\. P2 4 VV& EK \ PF ! V4 PI \J R 7 PM 4 PO ^4 PQ R1R!4 PR V R"& \ PF ! V4 PI \J R 7 PM 4 PO ^4 PQ R2R#4 PR V R$& V R", V R, , V R$, V R, , , V R%& M:\* PU R&V R'\( ^, R(24 V R, R3, V R%& V . R4O, p V P! V RR R 7 pV. R5O, PW 4 V. R5O& VR, P ^4 VR)& VR%, VR), ,
VR*& VR+, pVR*, PY VVR,7 PM 4 pVR*, PY VVR,7 P[ 4 pVR*, V,
V, VR-& VP% R-.R 7 P RR 7 # \D d EKo i ; i \D d8 p\* P] R.T 24 ^ RI/pTPa 4 Rp?R# Rp?ii ; i)6z.load_rate% r r r r r r r r r r r r c < SP 4 P R R/4 pV P 4 P R R/4 p\ P ! W#R RR7 # r r r s && rC r %_compute_eurusd_zscore..ffill1 r rB r r r r r r r r z6[EURUSD] z-score path: OLS (full model) | daily bars: r r r r r r z@[EURUSD] z-score path: FALLBACK (hardcoded -0.03) | daily bars: r r eurusd_return_24h lag_gap_24hr r r z[EURUSD] zscore error: r r r r r r r r ) prices_1hr r" r# r r r r r r r$ r% r& r' r( r) r* r+ r, r- rh r/ r r r_ r r s && @rC r r s H$ NN$ %j 1 4 4 > > @ & %%fu%=S /S0 [($)? (0'8'C'C'E#$ >>(6*:; B *v.+w/*v.+w/\\62== V "HV$4$8$8$:,F #G H
O V$**5w+?6*JE%V,E7eE'>RV\8] '76? B ' 0773C C *1+*>*C*CA*F%&*1,*?*D*DQ*G&'OPWWY>>'f&>AHH&'<= I ?h- kAo % HHMgYW XAgga(GRWWQ5G(;*! q}Q7<<> (=!>!B!B!Dq!H"()?"@"D"D"F"J!L Mv;#XOOF,ABX+Y$Z[' &&(:!;Q?CCEC"%**..1F"PGAJ"%**..1G"PHQK + $&99W#5#9#9{#9#K#P#P#R#X#XYZ#[#`#`afgk#l#s#sHY #%99X#6#:#: #:#L#Q#Q#S#Y#YZ[#\#a#abghl#m#t#tHZ #x0E'FF$x0F'GGH
* +
KKZ[bZccjkvyzkzj{{}~ .67L.MPU.UH* + gh
__X&f_
= S T Z Z \ OP"$W+"8"8"< "$%:";bAT>U"U=:- (((:??A- (((:>>@=)D0C78 yy
y+77T7BB' !&$&( +A3/0)--/s> M X> $BX+%IX> + X;6X> :X;;X> > Z ,Y;;Z c
VR, w r#VR, pR pV! V R2V4 pV! V R2V4 p\ P ! WgRRR7 P R4 pVP R4 pVP \ P
! VP P 4 VP P 4 RR 7 4 P 4 P 4 pW, W, ,
VR
& VR
, P WDR 7 P 4 VR & VR
, P WDR 7 P 4 VR
& VR
, VR , ,
VR
, , VR& VP R.R7 pVR, P 4 p RR.V n \ P ! V R, 4 P# R4 V R& V P% 4 p \ P ! V R, 4 P# R4 V R& \ P& ! V P R4 V P R4 RRRR7 p
V
P( ' g$ \+ V
R, P, R , 4 MRp \. P1 R\3 V4 RV R
RVR
, P, R , R
RVR , P, R , R
RVR
, P, R , R
R2 4 V
P R.R7 P R R 7 # \4 d7 p \. P7 R T 24 ^ R I qP; 4 R p ? R # R p ? ii ; i)!u
USDJPY: z-score of US-JP 2Y spread level.
CRITICAL: z_window=30 means 30 CALENDAR DAYS on daily spread data —
this matches the backtest exactly. Rolling on hourly bars would give
a 30-hour window which produces a completely wrong signal.
Method:
1. Build daily spread series (us2y - jp2y)
2. Compute 30-day rolling z-score on DAILY data
3. Forward-fill daily z-score onto hourly bars
r! r c D \ V , p\ P ! VR .R7 pVP Uu. uF qDP 4 NK upVn \ P
! W1, RR7 W1& VR V., P
4 P R 4 # u upi r r r s && rC r )_compute_spread_zscore..load_ratew r r z.csvr outerr r r spreadr z_meanz_stdr r r r r )left_onright_onr# z$[USDJPY] Spread z-score computed on z daily bars | current z=.4fz
| spread=z% (mean=z std=r Tr z[USDJPY] zscore error: N) rY r
ra set_indexreindexr rV r r r r r r r r rt rZ r r r emptyr[ r rU r r rT rL r r )r7 r spread_col1 spread_col2r/ r r1r2r0 daily_zrh current_zr_ r s && rC r r f s 9#&}#5
O B + d+[
9
+ d+[
9F8DDVL'
MM%++//+U[[__->S I
%'&&( ,u/AAh /11!1CHHJh /11!1CGGIg ?U8_<gNh XJ / /--/!8, .. 9@@AQR NN$ " j !!##)6*:#; * ]] ! !* - '
9;E"X,++B/0c 7E
| D '_ - ?//3C8 9 /..r237 8 g++B/4A 7 8 yy
y+77T7BB +A3/0--/s L L M!++M M!c \ V , R , F w r#pY!u;8: d V8 g K Vu # K \ V , R , R, ^, # )r rC )r) )r+ r& lohimults && rC get_multiplierrQ sN #D).99
b K ! : t ^ ,R 0 33rB c
^ RI p\ V , pVP 4 pVf R# VP p\ W4 pRpV R8X d VP R4 ' d \ P R/ 4 P RR4 pV' g9 \ VP R R4 4 p\ P R
V R V R 24 M\ P R
V R
24 V\ , V, V, p VP VR, 4 p
VR, p VR, p V R8X dO VP VR, 4 p
V
' d
V
P MRpV R, V, pW, V , pM%V
' d V
P ^
, MRpW, pV VV, , pV
' d
V
P MRpV
' d
V
P MRpV
' d
V
P" MRp\% V\' V\) VV, 4 V, 4 4 p\ P R
V RVR
RV R
RV RVR
2
4 V# \* d' p\ P- R
T RT 24 Rp?R# Rp?ii ; i) r Nr* ?r r r( r Fr r0 z ] Boost xu$ applied — no USDJPY position openu6 ] Boost skipped — USDJPY position open (normal size)r r r g b@i g $@g Y@z ] Lot size: .2fz
| Risk: $,.0fz | Mult: zx | Balance: $z ] calculate_lot_size error: )ry r) account_infobalancerQ rR r2 r[ rU r
BASE_RISK_PCT symbol_infor r trade_tick_value
volume_min
volume_max volume_stepr r r> rT rL )r+ r& r r accountrW
multiplierboostuj_open risk_dollarrY r r r price pip_value stop_pipslot_sizemin_lotmax_lotlot_stepr_ s && rC calculate_lot_sizerj s* (! &%%' ?4 __#D5
8 (< = = nnXr266NG cgglC 891TF)E72VWX1TF"XYZ },z9EA ooc(m4 *o*o 8 ''H
6D $DHH%E 7*U2I (83I >I 44r9dI +I )i"78.9;))t.9;))u.9;**twGU8h3F-G(-R ST 1TF,xnJ{4>P Q$ ^GD>C D AdV7s;<sH %I 6I -I B · z
FTMO passr )rI u? 📊 LOT SIZE BY NOTIONAL — pick one & stick to itu> (based on a fresh $100k USD account · TP/SL identical)) TIER_SCALESr r )rf r labelscalepassratelotss & rC format_tier_lotsrq sW
SE"- h
veWHT$K7KH:U_`a #. 99U rB c ^ RI p\ V , pVR, pVR, pVR, p VR, p
V^8X dB VP p \ V^V, , V
4 p \ V^V ,
, V
4 p
M@VP p \ V^V,
, V
4 p \ V^V , , V
4 p
RVP
RVRVRV R VR
V
R V R R
RRVR
2RVP RVP R^/ pVP V4 pVf \ P RV R24 R# VP VP 8w d5 \ P RV RVP RVP 24 R# \ P RT RVP RV^8X d RMR R V R V R V R V
24 VP # \ d' p\ P RT R T 24 Rp?R# Rp?ii ; i)!r Nr r r r' actionrr typerc sltpmagic4commentzz-score rT type_time type_filling deviationr0 z] order_send returned Nonez] order_send failed: r z] Order placed: ticket=z dir=BUYSELLz lots=z entry=z tp=z sl=z] place_order error: )ry r) ORDER_TYPE_BUYr> ORDER_TYPE_SELLTRADE_ACTION_DEALORDER_TIME_GTCORDER_FILLING_IOC
order_sendrU rL retcodeTRADE_RETCODE_DONEry r orderrT )r+ signalr rf r& r r r r sl_pctr'
order_typerv ru r r r_ s &&&&& rC place_orderr s *! d#h-h-j/d) Q; ++J{a&j126B{a&j126B ,,J{a&j126B{a&j126B C 1 1 F H J K B B H hz#&6 7 C . . C 1 1 B
( > II$ 9: ; >>S 3 3 3 II$ 4V^^4DAfnnEUV W 1TF1&,, @!'7 8!
'+ d2$d2$H I || AdV045s& D'G +A
G :AG G4G//G4c ^ RI p\ V , R, pVP VR7 pV' g \ P RV RV R24 R# V^ , pVP
VP 8X d
VP M VP pVP V4 pWsP 8X d
VP M VP p RVP RVR VP R
VR VR V R
RRVRVP RVP R^/ p
VP! V
4 p V ' d< V P" VP$ 8X d! \ P RV RV RV 24 R# \ P' RT RV ' d
V P" MR 24 R# \( d' p \ P' RT RT 24 Rp ? R# Rp ? ii ; i)r Nr ticketr0 z ] Position u not found — already closedTrs rr rt positionrc rw rx ry rz r{ r| u closed — reason: z] Close failed: NoneFz ] close_position_market error: )ry r)
positions_getrU r rt POSITION_TYPE_BUYr r r r r r rr r r r r r rL rT )
r+ r reasonr r positionspossider rc r r r_ s
&&& rC close_position_marketr " s ! T"8,%%V%4 HHqk&1NO P|&)hh#2G2G&Gs""SM_M_##F+ #5#55txx488 C 1 1 F CJJ D F E H F C . . C 1 1 B
$ fnn(>(>> HHqk&1EfXN O AdV+fFNN&+QRS AdV:1#>?s5 1F F C
F 9F F 6F F=F88F=c ^ RI p\ V , R, pVf R# VP VR7 p\ V4 # \ d R# i ; i)r Nr Fr )ry r2 r r rT )r+ r r r s & rC check_position_statusr E sK #!D!"34 >%%%V%4 I "U"s = = A A c ^ RI p\ V , R, pVP V4 pVf R# VP VP 8H # \
d R# i ; i)a Return True if the broker market is open and fully tradeable.
Used by hold-limit, z-exit, and broker-detected-close paths to avoid
attempting to close positions when markets are closed. Saturday's bug:
v3 attempted hold-limit close while UJ was closed weekend, MT5 returned
error 10018 (TRADE_RETCODE_MARKET_CLOSED), but v3 didn't check and
proceeded to mark the position closed in state anyway. Result: state
diverged from broker truth and v3 lost track of the open position.
Nr F)ry r) rY
trade_modeSYMBOL_TRADE_MODE_FULLrT )r+ r r sis & rC _is_market_tradeabler N sV ! T"8,
__V
$
:}} : ::: s -A
A
AAc R \ V , R& V\ V , R& V\ V , R& \ P ! \ P 4 \ V , R& V\ V , R& \ V 4 \ P RT RV^8X d RMR R
VR \ V , R , R
2
24 \ V 4 R# )Tr" r# r$ r% r& r0 z] Armed | dir=LONGSHORTz target=.r' fN)
r3 r rf r rp r6 rU r r) _schedule_fast_poll)r+ r# r$ r& s &&&&rC arm_fast_pollingr d s '+JtX '0Jt[!'3Jt^$'/||HLL'AJt\"'1Jt\"tHHqny!|V$I J#Ak$&7&=%>a#?@B C rB c R \ V , R& V \ 9 d8 \ V , ' d% \ V , P 4 R\ V & \ V 4 \ P RV RV 24 R# )Fr" Nr0 u ] Disarmed — )r3 _fast_poll_timercancelr6 rU r )r+ r s &&rC disarm_fast_pollingr o sb !&JtX $4T$:$: %%'!% tHHqofX
./rB c ~ a \ P ! R V 3R l4 pRVn VP 4 V\ S & R# )rS c < \ S 4 # N)_run_fast_pollr* s rC %_schedule_fast_poll..~ s
)=rB TN) threadingTimerdaemonstartr )r+ timers f rC r r w s1
OOC!= >EEL KKM "TrB c \ V , R , ' g R# \ V , p\ V , p\ V , p\ P ! \
P 4 pWAR, ,
P 4 R, pVR8 d \ V R4 R# VR, ' d R# \ VR, 4 pVf \ V 4 R# Vw rxVR, p VR , p
V ^8X d W8* p Tp MWz8 p Tp V ' g \ V 4 R# V^<, p
\ P R
T R V ^8X d R MR
RV RVR, R2
RV
R
R2 4 VR, p\ W4 pVR8 d \ V R4 R# \ W WV4 pV' Ed RVR& VVR& WR& WR& VP RR 7 VR & WR & VP! R 4 ' d% VR , \# VR , R 7 , VR!& \ V R"4 VR, pV ^8X d V ^VR#, , , MV ^VR#, ,
, pV ^8X d V ^VR$, ,
, MV ^VR$, , , p^
V^,
) , pV ^8X d W,
MW,
pVV, pV^ 8w d VR%
R&2MR'p\ P R
V R(V R)V
RV R2
R*V RV R2
R+2 4 \% R,T R-V ^8X d R MR
R.V RV R2
R/V
RV R2
R0V R1VR2
R3VRV R2
R4VRV R2
R5V 2R6, \' V4 , 4 R# \ V R74 R# \( d2 p\ P+ R
T R8T 24 \ T 4 Rp?R# Rp?ii ; i)9r" Nr% r8 r9 z 6h expiryr r r# r$ r0 z] TARGET HIT | r r z | price=r r' r | .0fzm since signalr& r* zlot size errorTr r r tzinfor r r hoursr. z order placedr r +.1fr? z0.0pz] Entry slip vs target: z (target=z, fill=r u 📈 [z!] ORDER PLACED
Direction: z
Entry: z
Target was: z (slip z)
Lots: rT z
TP: z
SL: z
Ticket: r z order failedz] fast poll error: )r3 r2 r) r rf r rp r= r r r rU r rj r rl rR r r rq rT rL )r+ r4 stater rf
elapsed_hoursrk r r r# r5 entry_hit
exec_price elapsed_minr& rf r r' tp_pxsl_pxr raw_slip slip_pipsslip_strr_ s & rC r r s d H % %N"D!D! T" hll+ \ 22AACdJ
C k 2 ! ! H
. > % +& .) > I J I J % #b( 1TF/IqL&g)N O$Qs4ykN33 $N4 5 <(
'9 d? &6 7 TjJO 6'+E/ "'-E# $'0# $'1- '*{{${'?E, '/. !ww-..*/ *= 45A7 +7&' n 5$iB6?lj!CM/2
TUVYZbVcTcHdE8A1 j!C
O"34*VWX[\fXgVgJhE QiH1:a ,jFYH 8+I09Q9T*!,FH HHq 6xj A &qAggj2$a5HK
L D6 "!+4a<W E F$Qrd!G, - %at1WoWXJ ?!# ' Qrd!Gn % Qrd!Gn %!($ *(34
n 5 " AdV.qc23D!!"sD BM "M 3!M 1M M A(M ?GM M N
&NN
c \ \ V , R , , pVP 4 ' d' \ P ! VP RR7 4 M. pVP
RV RVRVRVRVR\ V^4 R \ P ! 4 P 4 /4 VP \ P ! V^R
7 RR7 \ R V 4 4 p\ P R V R
\! V4 RVR
24 R# \" d' p \ P% R T RT 24 Rp ? R# Rp ? ii ; i)r% r5 r6 r+ r r r# rf net_pnl closed_atrd c 3 2 " T F
qR , x K R# 5ir NrA r r s & rC r %save_trade_history.. s 1&QiLL& r0 z] Trade history: z trades | total=$rT z ] trade history save failed: N)r@ r) rN rO rP rQ r r> r rf rg ri rj sumrU r r rT rV )
r+ r r r# rf r r\ tradestotalr_ s
&&&&&& rC save_trade_historyr s @T*;77AE DNNGN <=TV
4 6 ; 9 8 5!, 8<<>335
6!4wG1&11 1TF+CK=8I%PSUV @ av :1#>??@s 4D CD D?D::D?c ^ RI p \ P
! \ P 4 pT\ T R7 ,
pTP Y24 pTf \ P R4 R# ^ p^p/ pT FV pTP YV39 d K TP ' g K+ TP TP . 4 P T4 KX ^ p ^ p
^ p \ P 4 EF w rT
R, p\ T
R, , p TP# 4 ' d' \$ P& ! TP) RR7 4 M. pT Uu/ uF p\- TP/ R ^ 4 4 TbK! pp\1 TP3 4 4 p. p^ pTP 4 EFI w ppT Uu. uF qP4 T8X g K TNK ppT' g K4 \7 T4 ^8 dH TP \- T4 R
7 pT' d% \7 T4 \7 T4 8 d \9 T4 p\; TR R 7 p\7 T4 ^8 d K \= R
T 4 4 p\- T4 T9 d T\- T4 , p\? TP/ RR4 4 p T R8X d \A T4 R8 dq \C T^4 TR& \ PD ! TR8, PF 4 PI 4 TR& T^,
p\ PK RT RT RTR
R24 T
^,
p
EK T^ , p TR8, p T PL p T P T8X d ^MR8p T PN p!Tp"\ PD ! T PF 4 PI 4 p#TP RT R \- T4 R\C T T
R, 4 RT R\C T!^4 R\C T"^4 RT#/4 EKL T' g T' g EK \9 TPQ 4 4 T, p$T$PS R R 7 TPU \$ PV ! T$^R 7 RR7 T \7 T4 ,
p T T,
p T Fs pTR, ^ 8 d R MR p%\ PK R T RTR , R!TR, ^8X d R"MR# R$TR, R%T% R&TR, R'
R(TR, R), 24 Ku EK T ^ 8 g T ^ 8 dJ \ PK R*T R+T R,T
R-24 T ^ 8 d R.T R/2MR p&\Y R0T R1T& R2T
R3T R42 4 R# \ PK R5T
R624 R# \ d \ P R4 R# i ; i \* d . p ELWi ; iu upi u upi \* d R# i ; i \* d8 p'\ P R7T' 24 ^ RI-p(T(P] 4 Rp'?'R# Rp'?'ii ; i)9a
Startup-time reconciliation. Scans MT5 deal history and back-fills any
closed trades missing from the trade_history JSON files.
Logic:
1. Load existing tickets from each pair's trade_history file
2. Query MT5 history_deals_get() for the last N days
3. Group deals by position_id (ticket) + symbol
4. For any ticket not already in the JSON, compute net P&L from its
deals (entry + exit + commission + swap) and append to JSON
5. Report: "reconciled N missing trades" or "all X trades in sync"
Nz+Reconciliation: MT5 not available, skippingdaysz.Reconciliation: MT5 deal history returned Noner r% r5 r6 r r c V P # r rm ds &rC r 2reconcile_trade_history_from_mt5..8 s affrB keyc 3 ~ " T F3 pVP VP , VP , x K5 R # 5ir profitswap
commissionr r s & rC r 3reconcile_trade_history_from_mt5..= s0 "7+5a #$((QVV"3all"B"B+5s ;=r rA r* r z[RECONCILE-HEAL] z ticket u" — net_pnl was $0.00, MT5 says $+,.2fu — correctedr+ r r' r# rf c & V P R R4 # )r rI rR )r s &rC r r m s AEE+r,BrB rd +rI z [RECONCILE] — r r @ r $,.2fu · closed r z[RECONCILE] Back-filled z missing trade(s), healed z stale-zero entries (z already in sync)z Healed: z stale-zero entries
ue 🔄 TRADE HISTORY RECONCILED
────────────────
Back-filled z missing trade(s)
ud from MT5 deal history on startup.
────────────────
Already in sync: z
Lookback: z daysz#[RECONCILE] Trade history in sync (z trades verified)zReconciliation failed: rC )/ry ImportErrorrU rV r rf r rp r history_deals_getrt position_id
setdefaultr r) r r@ rN rO rP rQ rT intrR rM keysr r r rW r r[ r r>
fromtimestamprm rg r rc rr r sortri rj r r r ))
lookback_daysr rf r dealsDEAL_BUY DEAL_SELL by_positionr total_reconciledtotal_already_synced total_healedr+ r r r\ r
r existing_by_ticketexisting_ticketsto_addhealed_in_pairpos_id pos_deals
pair_deals pos_specific mt5_net_pnlexisting_entry existing_pnl
entry_deal
close_dealr r# rf r r r sign healed_liner_ r s) & rC reconcile_trade_history_from_mt5r s !
N0ll8<<(i]33%%e1 = KKH I Avvh 22=== " "1==" 5 < +=+=i+M%NL#s*s;/?$/F49+q4Iy1 % 2 2:b>3F3F G Q Q S '{3 '!+#4TF(6( K%%0$7~"G H )A-( ']
'^
( . . !+ H!Q CK/ N2 A"#I,!"33DHH|D6!H+ e*+K.!*; I J""#M"2!34vQq|D>Q R''(~c':&; = > m -z a !!.u6
HH -..?A
B[ ABB
"P J@
0 -aS12)--//0s U( A!V? *0V? A.V?
>VV? %V#1:V? +V(V(H-V? 6V? D"V? $'V-
V? ( V V
V V? V
V? - V<8V? ;V<<V? ? X
,W<<Xc ^ RI Hp \ P ! V ! R4 4 # \ d[ \ P ! \
P 4 p^TP u;8: d ^
8: d M M^M^pT\ TR7 , u # i ; i)u
Return current datetime in Eastern European Time (EET in winter, EEST
in summer). Uses the Europe/Helsinki zone — both EE timezone variants
follow DST consistently with that anchor.
Previous implementation used a naive `(UTC.hour + 2) % 24` which was
correct in winter but 1 hour off in summer (DST), causing v3 to skip
legitimate signals during the first hour of EEST sessions. Caught
2026-05-18 when EU broke threshold at z=-3.12 inside the validated
09:00-18:00 EET window but v3 logged "outside session — skipping".
)ZoneInfozEurope/Helsinkir ) zoneinfor r rf rT r rp monthr )r rp offsets rC _eet_nowr si -%||H%6 788 - ll8<<(399**YV,,, -s !$ A"B B c \ V , p\ 4 P pVR , Tu;8* ;' d
VR, 8* # u # )r r )r) r hour)r+ r r s & rC
in_sessionr s: t C :??D 4 = =3}+= == ==rB i c ^ RI p \ P ! 4 p\ VP VP VP
4 pV P
W!\ ^R7 , 4 ;' g . pRpV F^ p\ VRR4 R9 g K VP ^8X g K* WEP VP , VP , ,
pK` \ RV) 4 # )u Positive $ of today's realized EU+UJ loss (UTC day; 0 if in profit).
Coarse guard — FTMO's reset is CE(S)T midnight, ±2h boundary slack is
acceptable for a tail-only circuit breaker.Nr rA r rI r r( )ry r r< yearr dayr r getattrentryr r r r )r rf r r pnlr s rC _todays_realized_lossr s OO C SXXsyy#'' 2E ! !%yq/A)A B H HbE
C
1h #'; ;1 88aff$q||3 3C sSD>rB c ^ RI p^ RIp^ RIHp ^p\ P ! VP
4 pV\
^R7 ,
p^ pRp . p
Rp \ ^V^, 4 EF p VP VR7 p
V
' g VP Wv4 p
V
f/ \ P RV RV 24 VP V 4 Ka V
Uu. uF qP V8X g K VNK p
pV
Uu. uF p\ VRR4 V8X g K VNK ppV' d1 V^ , p V ^8 d \ P RV R V R
V 24 MD\ P RV R V R
V R \ V
4 R
V R2 4 VP V 4 EK# V
' g" \ P RV RV RV R24 R(# V f@ \ P RV RV R24 \! R V
4 4 p\# V
R R7 pRpM\! R V
4 4 pT pRpVP$ pVP& ' d VP& P) 4 MRpR V9 g R V9 d R pMR V9 g R V9 d R!pMRp\ P RV R"VR#
R$V R%V R&V 2
4 \+ V^4 VVV3# u upi u upi \, d( p\ P RT R'T 24 R(u Rp?# Rp?ii ; i))uz
Pull closed trade P&L from MT5 deal history.
Returns (net_pnl, close_price, reason, pnl_confident).
pnl_confident is True when we found the exit deal cleanly and net_pnl
reflects real broker numbers. False when retries were exhausted and
net_pnl may be approximate or zero-by-default.
PATCHED 2026-05-06: Retries with backoff to handle MT5 history table
population delay. The MT5 history_deals_get() result updates asynchronously
after a position closes — typical delay 100-2000ms. Without retry, we
sometimes find only the entry deal (profit=0) or partial data and report
wrong P&L on closes.
PATCHED 2026-05-14: Added confidence flag so the Telegram close
message can avoid the misleading "BREAK EVEN" label when P&L is
really just "unknown — exit deal wasn't in MT5 history table yet".
Strategy:
• Filter strictly by position_id (no fallback to symbol-wide search,
which previously caused cross-ticket P&L contamination)
• Look specifically for the EXIT deal (entry == DEAL_ENTRY_OUT)
• Retry up to 6 times with 1-second waits (max 6s wait total)
• Sum profit/swap/commission across all deals for this ticket only
Nr r r r r0 z-] history_deals_get returned None on attempt r z ] Exit deal found on attempt r z(] Exit deal not yet in history (attempt z, found u deals for ticket) — waiting rn z ] No deals found for ticket z after z attemptsTP/SLFz!] Exit deal never appeared after uM s — using all matched deals as-is (P&L may be 0 if exit deal still pending)c 3 | " T F2 qP VP , VP , x K4 R # 5ir r r s & rC r "_get_closed_pnl.. ' Qy!XX . = =y :<c V P # r r r s &rC r !_get_closed_pnl.. s affrB r c 3 | " T F2 qP VP , VP , x K4 R # 5ir r r s & rC r r" r# r$ TrI rv z take profitu Take Profit ✅ru z stop lossu
Stop Loss ❌z] Close P&L from MT5: $rT z | close_px=z
| reason=z
| confident=z] _get_closed_pnl error: )rA Nr F)ry rm r r rf rp r r r rU rV sleepr r r r r r rc ry r r> rT )r+ r r _timer DEAL_ENTRY_OUTrf r max_attempts wait_secondsr exit_dealattemptr r
exit_dealsr r
pnl_confidentclose_pxry r r_ s && rC _get_closed_pnlr2 s 4X)! % X\\*iQ'' Q q 01G ))6):E--e9} av%RSZR[ \] L) %*EEq]]f-DEIE &/ JY $Q 6. H !YJ J &qM Q;HHq&CG9Al^ \] HHq !!( <. 9 !)n --L\NZ[]
^
KK %9 2> KK!D6!=fXW\NZcd e, , KK!D6!B'. )DE
F Qy QQG Y,<=J !M Qy QQG"J M ## 1;0B0B0B*$$**, 7?mw 6&F
W_ w 6$F F 1TF1'# ? %Jj 9 +_. / Wa (FMAAe FJb ) av 6qc:;(()s] CJ$ J J"J$ (J J BJ$
J$ .A6J$ %A4J$
J$ $ K/ K KKc \ V , p\ V , p\ V , pVR, pVR, p\ P RV RVP RR4 R24 VP RR4 pVR8X d< \
WAP R R
4 4 pVf \ P RV R 24 R # M:\ WAP R
R4 4 pVf \ P RV R24 R # \ W4 pVe \ V4 ^8 d \ P RV R24 R # \ VR, P R~, 4 p WR& \ P RV RV R
RVR, R24 VR, ' Ed VR, Ee \ V 4 p
V
' Eg' VR, p VR, p VR, p
VP R^ 4 p\ P RV R V 24 \ W 4 w ppppR VR& R VR& R VR& R VR& R VR & \ V 4 V ' d V
e \! W WW4 \ V , R, pV^ 8 d R VR
2MR!\# V4 R
2pV^ 8 d R"pMV^ 8 d R#pMR$pR%pV
^8X d R&MR'pV' d VR(V R)2
MR*p\% R+V R,V R-V R.V R(V R)2
R/V R0V R1VR2
R3V R424 R # VR , Ee \& P( ! 4 VR , ,
P+ 4 R5, pVVR6, 8 Ed \- V 4 ' g+ \ P RV R7VR8
R924 \ V 4 R # \ P RV R7VR8
R:24 VR, pVR, pVR, pVP R^ 4 p\/ V VR;4 p \ V 4 p
V ' d V
' d- \ P RV R24 \ V 4 R # \ V V4 w p p p p R VR& R VR& R VR& R VR& R VR & \ V 4 V' d Ve \! V VVVVV 4 \ V , R, p!V ^ 8 d
R V R
2p"R"p#M V ^ 8 d R!\# V 4 R
2p"R#p#MR%p"R$p#\% R?V R@VR6, RAV# RBV" R42 4 R # VRC, Ee VR, p$V$^8X d WRC, ) 8: g V$R~8X Ed WRC, 8 Edr \- V 4 ' g+ \ P RV RDV RE
RF24 \ V 4 R # \ P RV RDV RE
24 VR, p%VR, p&VR, p'VP R^ 4 p(\/ V V%RG4 p)\ V 4 p*V)' d V*' d- \ P RV RHV) R=V* R>24 \ V 4 R # \ V V%4 w p+p,p p-R VR& R VR& R VR& R VR& R VR & \ V 4 V&' d V'e \! V V%V&V'V(V+4 V+^ 8 d
R V+R
2p.R"p/M V+^ 8 d R!\# V+4 R
2p.R#p/MR%p.R$p/\% RIV RJV RE
RKV/ RBV. R42 4 R # \ P RV RLVR, RMVR, 24 \ V 4 R # \# V 4 VR, 8 d \1 V 4 ' gY \ V , p0\3 4 P4 p1\ P RV RNV1RO
RPV0RQ, RO
RRV0RS, RO
RTV RE
2
4 M0\ P RV RU\# V 4 RE
RVVR, R24 \ V 4 R # \1 V 4 ' g4 \ P RV RW\# V 4 RE
RX24 \ V 4 R # \7 4 \8 8 d; \ P RV RY\7 4 RZ
R[\8 RZ
R\24 \ V 4 R # \ V , P R_4 p3VP R`4 ' d V3' d \= V3\> 4 ' d \& P@ ! V34 p3V3' d[ \& PB ! 4 V38 dA \ P RV RW\# V 4 RE
RaV3 RbVR`, Rc2 4 \ V 4 R # VRd, ' d \ P RV Re24 R # WR, 8 d ^MR~p4\# V 4 p5VP R4 R8X dK VP R, p6\ V6Rf, 4 p7\ V6Rg, 4 p8\ V6Rh, 4 p9M\
V^
4 p:V:e V:PD ' d \ P RV Ri24 R # V:P R~, p;\ V;Rf, 4 p7\ V;Rg, 4 p8\ V;Rh, 4 p9V4^8X di V9V8,
p[uR ] POSITION CLOSED
────────────────
Result: z
Direction: z
Entry: z
Close: z
Reason: z
Lots: rT u>
────────────────
Net P&L: r8 r
z] Hold limit reached (r: u. h) but market closed — will retry next checku h) — closing
time_limitz-] Hold-limit close did NOT succeed (close_ok=z
, still_open=u& ) — leaving state intact, will retryu ⏱️ [u% ] POSITION CLOSED — hold limit z
h
Result: z
Net P&L: r z] Z-exit triggered at z=.3fu, but market closed — will retry next checkzscore_reversalz)] Z-exit close did NOT succeed (close_ok=u 🔄 [z ] Z-EXIT TRIGGERED
Z-score: z
Result: u% ] Position open — holding | ticket=z | entry=z] Outside trading window (02dz:00 EET | session r u :00–r z
:00 EET) | z=z] No signal (|z|=z < z
] Signal |z|=u outside session — skippingu- ] Signal suppressed — daily realized loss $rU z >= $z haltz ] daily-loss halt check failed (u ) — continuingr. r u% suppressed — entry cooldown until z UTC (one entry per zh, matches backtest)r" u( ] Already armed — fast polling runningrv rw rx z] No 15M bars for Fib entryr z ] SIGNAL z=+.3fz& dir=LONG NOT ARMED: bar pull (C-L) = i' zp < 1.0p Fib guard | bar H=z.5fz L=z C=r z' dir=SHORT NOT ARMED: bar pull (H-C) = z] SIGNAL DETECTED | z=z | dir=z
| target=u 🎯 [z"] SIGNAL DETECTED
Z-score: u (threshold ±z)
Direction: z
Fib target: z"
Watching for entry (6h window)...rC )$r) r2 r3 rU r rR r rV r r r r[ r r r2 r6 r r r r rf r= r r r r r r DAILY_LOSS_HALTrT r rJ r; r< rF r )>r+ r r r4 r r' timeframer rh rL
still_openr entry_px entry_dir
entry_lotsr r1 close_reasonr0 pnl_strr dir_str close_strelapsedticket_h
entry_px_h entry_dir_h entry_lots_hclose_ok net_pnl_h
close_px_h_pnl_confident_hdp_h pnl_str_hresult_hdir_openticket_z
entry_px_z entry_dir_z entry_lots_z
close_ok_z still_open_z net_pnl_z
close_px_zpnl_confident_z pnl_str_zresult_zcfg2hour_eet_ecd_untilr# r&
signal_barbhblbcr$ last_barpullr5 s> & rC run_signal_check_pairrl 8 s C t E t E MF IBHHq=cggFXZ^>_=``a
bc *D1IE S)AB KK!D6!;< = 3(?@ KK!D6!:; <
(B zSWq[ av 9:;bl''+,I$-HHqk)C s;?O>PPQ
RS
_ %(9":"F*40
z 01F }-H 01I >15J HHq I&R S=LT=Z :GX|]',E/ "'+E# $'+E# $'+E- '+E, t I 1"4#-8 "$'-B-4\74.)CLQUCV?WG {%1#
A2 )QfGG088AbT7+eI D6 " $X & %Y '#AbT7+ ,$+ &'. )%c* + &it -
* ||~l(;;JJLtSG#l++
,D11HHq&B9X #>+D11HHq&>yo NK L M t$1TF":9S/JK #$5 6 #M 2
#$5 6 #ii : 3D(DU V
4T : "|KK!D6 *--7L
l^ TG!H I t$TTY[
\ t 6 $ ##$45H
ww%&&8 h $ $ $ 2 28 < )H4 HHqmC N3+? @--5J 7''*+A'B&CCWY
Z
t X 1TFBCD!%5512Iy>J ww!"e+ WWR[
:f%
&
:e$
%
:g&
' + x~~~ KK!D6!<= > ==$
8F#
$
8E?
#
8G$
%A~Bw 6>
HHqk)D)9 :))-eC(8 9 XSCBs8=
>
t c%j4''Bw 6> HHqk)D)9 :))-eC(8 9 XSCBs8=
>
t c%j4''HHq C )Q,G'L M at1Wo' (
D6 o%7K8H7I J#,a<W= > at1Wo &, - T9fj9tg T av =bTAQRSST -h -s+ A l2 <m' 2 m$= m m$'
m87m8c \ F p \ V 4 K \ 4 \ 4 R# \ d h \ d: p\ P RT RT 24 ^ RIq"P 4 Rp?Ku Rp?ii ; i \ d# p\ P RT 24 Rp?LRp?ii ; i \ d$ p\ P RT 24 Rp?R# Rp?ii ; i)z@Run signal check for all configured pairs. Fully exception-safe.r0 z] Signal check exception: NzLive P&L update failed: Account snapshot update failed: ) r) rl rK rT rU rL r r update_live_position_pnlrV update_account_snapshot)r+ r_ r s rC run_signal_checkrq s 4 !$ ' 4 "
< !! ! 4 II$ 9!= > 1 1 3 3 4 4 .qc2334 < 6qc:;; VP VP VP 3. 4 P V4 Kw \! VP# 4 4 F| w w ppp\% V4 ^8 g K V P VR7 pV' g K7 \% V4 \% V4 8 g KR V Uu. uF pVP V8X g K VNK upVVV3& K~ RRRR/pR^ R^ /pRpVP' 4 pVP# 4 F w w ppp\% V4 ^8 d K \) R V 4 4 pVV;;, V,
uu& VV;;, ^,
uu& \ P* ! \- R
V 4 4 4 pVP' 4 V8X g K VV,
pK RRRR/p R^ R^ /p R- F p \. \0 V , R , , p V P3 4 ' dL \4 P6 ! V P9 R R
7 4 p \% V 4 V V & \) R V 4 4 V V & K K / p!/ p"R- F p VV , V V , 8X d) V V , ^ 8 d VV , V!V & VV , V"V & K@ V V , V!V & V V , V"V & V V , VV , 8 g Ko \< P? RV RV V , RVV , R24 K \) V"PA 4 4 p#\- RV) 4 p$\) V!PA 4 4 p%VV%,
p&\C V&4 R8 d" \< P? RVR
RV%R
RV&R
24 RVPE 4 R\G V^4 R\G V^4 R\G V^4 R \G V%^4 R \G V$^4 R T#R V!P# 4 U'U(u/ uF w p'p(V'\G V(^4 bK up(p'R V"R!V/
p)\. R", p V PI R#4 p*V*PK \4 PL ! V)^R$7 R R
7 ^ RI'p+V+PQ \S V*4 \S V 4 4 \< P? R%VR&
R'V%R
R(V# R)V"R, R*V"R, R+V$R&
2 4 R# u upi \: d EK i ; iu up(p'i \T d R# \: d$ p,\< PW R,T, 24 Rp,?,R# Rp,?,ii ; i).u
Write authoritative MT5 account state + per-pair trade stats to
data/logs/account_snapshot.json so the dashboard server can display
real balance-derived P&L without needing its own MT5 connection.
Strategy — combines two sources to avoid MT5 deal-history quirks:
• Total P&L from MT5 balance − starting balance (perfectly accurate, net of fees)
• Per-pair trade count from the JSON trade history files (monitor's
authoritative record of which positions it executed — immune to
MT5 occasionally missing a position in history_deals_get grouping)
• Per-pair P&L: prefer MT5 deal-grouped sum if it matches the JSON
count, else use the JSON-derived sum (gross) and log a warning
Nr g j@r r r( r rA c 3 | " T F2 qP VP , VP , x K4 R # 5ir r r s & rC r *update_account_snapshot.. s' J 1hh'!,,66 r$ c 3 8 " T F qP x K R # 5ir r r s & rC r rt s 3NIqFFIs r% r5 r6 c 3 D " T F qP R ^ 4 x K R# 5ir r r s & rC r rt
s 0Ufy!1D1Dfs r0 z$] Snapshot: using JSON counts (JSON=z vs MT5=r g @z"[snapshot] account balance delta $r z vs strategy P&L $u — non-strategy activity $ snapshot_atrW equity floating_pnl pnl_total
daily_loss trade_countpair_pnl pair_tradesstarting_balanceaccount_snapshot.jsonrc rd zAccount snapshot: balance=$r u · P&L $u · trades=z (EU:z UJ:u ) · daily_loss=$z update_account_snapshot failed: r ),ry r r rV r[ rW rx rf rp r r rt r r r r r r r r r r r r@ r) rN rO rP rQ rT rU r r r rg r> rh ri rj rk rl rJ r rV )-r _tzSTARTING_BALANCEacctrW rx floatingaccount_balance_deltanow_utcr r r r our_symbolsr r _sym_pid_dl_ps mt5_pair_pnlmt5_pair_trades
today_pnl_mt5rH r r net
close_time
json_pair_pnljson_pair_tradesr+ r\ r final_pair_pnlfinal_pair_trades total_tradesr{ total_pnlnon_strategy_pnlr@ vsnapshotro rp r_ s- rC rp rp s O<!,$ ! < &%# !( : ,,sww'I2 ..''7 =E ) * Avvh 22xx{*=== " "AHHamm#>CSTXCY\]C]*6t*<t$*9$*?!$' +8*=t$*:4*@!$'#D)OD,AAHHq '&&6t&<%=XoVZF[E\\] _ ` ) ,3356 3 /
--/0
19< 3 & HH9:OPU9V W))25(9 ://?.FH
I
1 1 3 gq 1 fa 0 h 2 i 3 j! 4 NU;$A6V D V +V$B0V 6V ; V V
V V W"W+W,W
Wc
^ RI p \ P 4 EF w r TP R4 ' d TP R4 f) R F pTP TR4 K \
T4 KY \ T, pTR, pT P TR 7 pT' g K T^ , pTP R
4 ;' g
TP pTP R 4 p T P TR , 4 p
T
' g K T ^8X d
T
P M T
P p TR
, p T ^8X d Y,
T , MY,
T , p
RpRpTP R4 pT' d- \ T\ 4 ' d \ P ! T4 pT' dL \ P$ ! 4 T,
P' 4 R, p\) ^ TR, T,
4 p\+ YR, 4 TR& \+ \- TP. 4 ^4 TR& \+ T
^4 TR& Te
\+ T^4 MRTR& Te
\+ T^4 MRTR& \
T4 \0 P3 RT RTP. R
RT
R
RTR
RTR, R2 4 EK R# \ d R# i ; i \" d Rp EL0i ; i \" d( p\0 P5 RT RT 24 Rp?EK Rp?ii ; i) a
For any open position, query MT5 for current price + unrealized P&L
and persist to the state file so the dashboard can display floating P&L.
Writes these fields into state_{pair}.json when position_open=True:
current_price : latest bid/ask
floating_pnl : unrealized P&L in account currency (from MT5 position.profit)
floating_pips : distance from entry in pips
bars_held : hours held so far
bars_remaining : hours until hold_hours limit
Removes these fields when no position is open (keeps state clean).
Nr r
current_pricery
floating_pips bars_heldbars_remainingr r r r r r r8 r
r' r0 z
] Live P&L: $+.2fr r z
pips | held=r: h/hz] Live P&L update failed: )r ry r r r )ry r r2 r rR r r6 r) r
price_openr r r r rJ r r; rT rf r= r r> r[ r rU r rV )r r+ r r@ r r r r rB r# r
current_pxr r r r r r_ s rC ro ro I
s ! "'') 3 A99_--;L1M1U9AIIa&9 4 &C,-F)))8I #A,C ))M2DDcnnH ))$56I ..s8}=D&/1n$(($((J j/HDMQRNj 3x ?#+#8H"D
I !N <0J j#..&.&<&bfE" # t HHqmCJJt+.
s =f) fr )r rA )r@ rN rO rP rQ rR r r; rl rf r r= rT r) r r )
r+ snap_pathsnapsnap_atsnap_dtage_hr} pair_cntr\ r s
& rC _pair_trade_statsr
sr
55 ::i 1 1' :;Dhh}b1G & 4 4W__S(5S TG %\\'.. 9G C R R TW[ [E |#'88J#;#?#?c#J#'88M2#>#B#B4#K ' 11 $;t,[998<
DNN7 3426{C =f = === !
sN "F! >F! %B/F 4F2 AF2 F F! F F! ! F/.F/2
GGc : V ^ 8 d RV R
2# R\ V 4 R
2# )r r5 r r6 )r )tots &rC _format_pnlr
s( !QhRDz?@bS$,@@rB c \ V , pVP R 4 ' dW VP R4 pVP R4 p\ V , R, pV' d RV^8X d RMR RVRV R 2
2# R
# R # ) r r r r' u 🔵 r r r r r u 🔵 Openu ⚪ No position)r2 rR r) )r+ r epr r' s & rC _pair_position_strr
sw t E yy !!
YY}
%
YY(
)
t
$FHAv733r!B4qkBYkY rB c ~ R \ V ^
, 4 , R^
\ V ^
, 4 ,
, , # ) █ ░)r> r? s &rC _prob_barr
s* uQrT{*5"U1R4[.+AAArB c * V ^<8 d R# V ^#8 d R# R# < u 🟢u 🟡u ⚪rA r s &rC _prob_emojir
s QU6J!R%JUJrB c x a V' g R# V R8X d RMRpV' Ed\ \ VR R7 pRRV R2R .pV F pVR
, VR
, 8X d VR , ^8 d R MRpVR
, ' d' RP R VR
, R, 4 4 MRp VP \ VR , 4 R, VR, , R, \ VR , 4 , R, \ VR , 4 , R, V, R, V , 4 K VR RVR, , R, \ VR , 4 , R, .,
pRP V4 # \
V3R lV 4 R 4 p
V
' g` \
R V 4 R 4 p
V
' g R# \ P ! 4 P R 4 p \ V
4 p
V
R, R , V
R& V
R
, ' d' RP R! V
R
, R", 4 4 MR#p R$V, R%, V
R, , R&, \ V
R , 4 , R', \ V
R , 4 , R(, \ V
R , 4 , R), V , R*, # )+zDBuild the signal outlook section in the exact user-preferred format.rI r EURUSD SIGNAL OUTLOOKUSDJPY SIGNAL OUTLOOKc V R , # )probrA )xs &rC r (_build_outlook_section..
s 1V9rB r u 📅 WEEK AHEAD — r8 r r r u ⭐events, c 3 2 " T F
qR , x K R# 5i)eventNrA r r_ s & rC r )_build_outlook_section..
s A AwZZ r Nr N
No key eventsz r z % r
└ u ⭐ Best day: z at %r c 3 F <" T F qR , S8X g K Vx K R# 5ir NrA r r today_strs & rC r r
s @g6i)?11gs !
!Nc 3 > " T F qR , f K Vx K R# 5i)r NrA r s & rC r r
s C'QvYqq's
%az (next trading day)c 3 z " T F1 pR VR, , R, VR, , R, x K3 R# 5i)u • r r countryr NrA r s & rC r r
s6
%
7 #d *Qy\ 9C ? ?%s 9;N Nu! • No key macro events todayu
📅 TODAY'S r u6
────────────────
z Signal probability: z%
z
Key events:
u1
────────────────) r r r r rJ r r r rf r\ r1 ) r+ outlook is_mondayr
pair_labelbestr r starevstdday_names &&&f rC _build_outlook_sectionr
s ,0H,<(BYJyG!45 %j\ 6 >
A fIf 5!F)b.5bDEFx[[499 A8R AAVeC LLAfI&/!E(:XEAfI !&')21V9)=>@CDFJK "#
> $u+ -
:Sf =N NQT T
yy
@g@$
GC'CTJB ||~..t4HbB5 $99BuI \\ ii
\"%
C
!: - 7"U) C GA
A 6
#
$&@
A
6
O
(
(
bj !
"%
"
"
%?
?
rB c 4 \ P ! \ P 4 p\ e? V\ ,
P 4 R8 d V R8X d \ P R4 R # Vs\ P ! 4 P R4 p\ P ! 4 P 4 ^ 8H p\ R, P R4 pVe VR
MRpV' d \ V4 R , ^d, R
R 2MR p\ R4 w rx\ R
, P R4 p V e V R
MRp
V ' d \ V 4 R, ^d, R
R 2MR p \ R
4 w rW|, pW, pR pR p ^ RIHpHp T! \# T;' g ^ 4 4 pT! \# T ;' g ^ 4 4 p\% RVW24 p\% R
VW24 p\+ RV RV RV R\- R4 RV R\/ V4 RV
RV R\- R
4 RV R\/ V
4 RV R \/ V4 R V V 2 4 R # \& dO p\ P) RT 24 \ P ! 4 P R4 pRT R2pR p R p?LR p?ii ; i) N 📊 DAILY SUMMARYu5 Daily summary skipped — sent within last 30 minutesrS r r r: r7 r r z% of thresholdrI r( r get_weekly_outlookget_usdjpy_weekly_outlookzOutlook fetch failed: r u(
📅 TODAY'S EURUSD SIGNAL OUTLOOK — u
────────────────
Calendar unavailable — check log
────────────────zuU
────────────────
🟢 EURUSD
Z-score: z (z )
Position:
Trades:
| PnL: uQ
────────────────
🔵 USDJPY
Z-score: u<
────────────────
Combined: z trades | ur
System: ✅ Running
────────────────
Thresholds: EURUSD ±2.75 · USDJPY ±2.00)r rf r rp _LAST_DAILY_SUMMARY_SENTr= rU r r\ weekdayr2 rR r r execution.dashboard_serverr r r[ r rT rV r r r )header_nowr r eu_zeu_z_seu_pcteu_neu_totuj_zuj_z_suj_pctuj_nuj_totco_nco_toteu_outlook_textuj_outlook_textr r eu_outuj_outrd r s & rC send_daily_summaryr
s << %D ,00??ADH.. HI # ''
3I &&(A-I
!
%
%m
4D " .SzEF:>D $s"3'~
6BF$X.LD
!
%
%m
4D " .SzEF9=D #
c!#&n
52F$X.LD
[D
_FOO
$E$))!$45*5+;<0 fi40 fi4
fX hgfX .'12 3&
;v#6"7 8 hgfX .'12 3&
;v#6"7 8F,{6':&; <7
#
,RD12<<>**407z B?
@
s 2H> 3%H> > J AJJc
aa ^ RI Hp Hp \
R, P
R4 ;' g Rp\
R, P
R4 ;' g Rp T ! \ T4 4 pT! \ T4 4 pR oR
oTT3R lpT' d TR
MR
pT' d TR
MR
p\ R4 w r\ R4 w rY, p
Y, pT! TRR4 pT! TRR4 p\ RT RT RT
R\ T4 RT T 2 4 R# \ d \ RR7 R# i ; i \ d \ RR7 R# i ; i)u
Sunday 06:05 UTC — week-ahead outlook replacing the daily summary.
Shows full 5-day signal probability calendar for the coming week.
r u 📊 WEEKLY OUTLOOKr Nr r rA r( c b \ V ^
, 4 pRV, R^
V,
, , # )r r r )r )pctfilleds & rC _bar!send_weekly_summary.._bar_ s' S2X v~f 555rB c * V ^<8 d R# V ^#8 d R# R# r rA )r s &rC _icon"send_weekly_summary.._iconc s "9V "9VrB c b < V ' g R # \ V R R7 pVP R^ 4 pRV R2.pV F pVP R^ 4 pVP RR 4 pVP RR 4 p VP RR 4 p
S! V4 p WcJ d
V^ 8 d R
MR p VP V R V R VR , R
V RS
! V4 V RV
2 4 K VP R4 V^ 8 d( VP RVP R4 RV R24 VP RV 24 RP V4 # )rI c & V P R ^ 4 # )signal_probabilityr r s &rC r @send_weekly_summary.._build_week_block..k s AEE2F,JrB r r
u
📅 WEEK AHEAD — u5
────────────────r r top_eventr u ⭐r : NN r r r u ⭐ Best day: z at r z% = prob z-score crosses r )r rR r r )r rm threshold_labelbest_daybest_pctr r r r r topiconr r r s &&& rC _build_week_block.send_weekly_summary.._build_week_blockh sA "JK LL!5q9,UG3ijkAUU/3CUU6"%DUU5_CUU;7C3ZD }R VRD LL&#aRzC5DI;tf E %!
GI r> LL>(,,u*=)>d8*AN O
0 0ABCyy rB r: r7 r u ±2.75r u ±2.00ub 📆 WEEKLY OUTLOOK
────────────────
🟢 EURUSD z=u
🔵 USDJPY z=r r u
System: ✅ Running
) r r r rT r r2 rR r[ r r r )r r r r r r r r r r r r r r r eu_weekuj_weekr r s @@rC send_weekly_summaryr G sY
h # #M 2 9 9cD h # #M 2 9 9cD#E$K0*5;7
6
0 $c
F #c
F$X.LD$X.LD ;D
_F (?JG (?JG !!' )!!' )&
;v#6"7 8 ) ) u "78 "78s# D "D' D$#D$'EEc a \ R, P R4 p \ R, P R4 pV e V R
MRpVe VR
MRpR pV! RV 4 pV! RV4 pR p\ P ! 4 P R 4 oR
pR
p ^ R IHp
Hp T
! \ T ;' g ^ 4 4 p T ! \ T;' g ^ 4 4 p
V3R lpV! V 4 pV! V
4 p \ P ! 4 P R4 p\ RV RV RV RV! R4 RV RV RV RV! R4 RV R24 R# \ d# p\ P R
T 24 Rp?LRp?ii ; i)u1
Fires at 07:00 UTC (London open). Unlike the 06:05 daily summary which is
a full system report, this is a focused 'today's plan' briefing:
• Current z-scores with sizing tier info
• Top 3 scheduled events for each pair today (with times/forecasts)
• Position status with floating P&L if open
r r r( Nr= r7 c Vf R# \ V4 p\ V , pW#R, 8 d W#R, , ^d, pVR
R2# VR, F w rVpYRu;8: d
V8 g K M K RV R2u # RVR, R , ^, R2# )
Nr7 r
r u% % to signal (base 1.0× if triggered)r z would size u × at current zu × (max tier) at current zrC )r r) )r+ zabsZr r rN rO rP s && rC
_tier_text)send_morning_briefing.._tier_text s 9U1v$ k" "[))C/C#Y CD D / /LBDB$TF/:: 0 S 0 4Q 7 88RSSrB c h \ V , pVP R 4 ' g R# \ V , R, pVP R4 ^8X d RMRpVP R4 pVP R4 pVP R4 pVP R 4 p\ V , R
, pV R VR V R
2
2.p Ve$ V^ 8 d RMRp
V P RV
RVR
24 Ve# V^ 8 d RMRp
V P V
VR
R24 Ve V P VR
RV R24 RP V 4 # )r z No positionr' r r r r ry r r r
r r r r rI zP&L r r r: r? r r r )r2 rR r) r r ) r+ r r' rG r fpnlfpipsheld
hold_limitr r
s & rC _pos_line(send_morning_briefing.._pos_line s2 4 yy ))-
t
$ !II&7 8A =&7 -(yy ( /*yy% &|4
9Cat1W~./ !)3D LL4vQtDk2 3 1*3"D LLD6%A. / LLD:R
|15 6{{5!!rB rS zNo calendar datar c < \ V3R lV 4 R4 pV' d VP R4 ' g R# . pVR, R, F{ pVP RR4 ;' g RpVP RR4 pV' d R V 2MRpVP R
V R
VR , R VP R
R4 R, RV 24 K} RP V4 # )c 3 V <" T F qP R 4 S8X g K Vx K R# 5ir r r s & rC r ?send_morning_briefing.._format_today.. H'QUU6]i-Gqq' )
)Nr zNo key events todayr rm rI z--:--forecastu · Fcst r r r r r r r )r rR r r )r r r r_ time_strfcfc_partr s & rC
_format_today,send_morning_briefing.._format_today s H'H$OBRVVH - -,E\"%% 55,77UU:r*.0IbT*b r(2aj\AEE)BMORNING BRIEFING — uL
────────────────
🟢 EURUSD z=z
z
Position: z
Events today:
uH
────────────────
🔵 USDJPY z=u`
────────────────
London session: 07:00–17:00 EET · Good luck)
r2 rR r rf r\ r r r r[ rT rU rV r )r r r r r eu_tieruj_tierr' eu_today_eventsuj_today_eventsr r r r r2 r_ r r s @rC send_morning_briefingr8 s h # #M 2D h # #M 2D # /T{UF # /T{UF
T 4(G4(G", ''
3I(O(OC
$E$))!$45*5+;<
$ (/'/ ||~&&{3H
'z 2!!' )Y !(+, - , - .!!' )Y !(+, - , - .9 : C =aSABBCs$ D< 'D< !D< < E)E$$E)c V' d V ' g R# VP R4 w r#\ P ! V R4 P \ V4 \ V4 R7 p\ P
! \ P 4 P RR7 p^VP u;8 d ^ 8 d M M^M^ pV\ VR7 , pWG,
P 4 ^<, pV# \ d R# i ; i)z
Calendar times from FinanceFlow are already converted to UK time by the
dashboard_server's _fetch_te_calendar. Compare to current UK time.
Returns minutes until event (negative if already past), or None if unparseable.
N:rS )r minuter r ) rL r strptimerl r rf r rp r r r= rT ) event_date_strevent_time_strhhmmevent_dtr uk_offsetnow_uk delta_mins && rC _minutes_until_event_ukrE s ^ %%c*$$^Z@HHRR I
,,x||,44D4AW]]/R/AQ 9955 &557"< s C' C' CC' ' C65C6c z aaa ^ RI Hp Hp \ P ! 4 P R4 o\ R, P R4 ;' g Ro\ R, P R4 ;' g RoTTT3R lp T ! S4 pT! TR4 T! S4 pT! TR4 R# \ d$ p\ P RT 24 Rp?R# Rp?ii ; i \ d# p\ P R
T 24 Rp?LmRp?ii ; i \ d$ p\ P R T 24 Rp?R# Rp?ii ; i) a
Run every 5 minutes. Scans today's cached weekly outlook for any event
with score >= 80 (FOMC, ECB rate decision, CPI, NFP, BoJ) that's
scheduled to release in the next 30-35 minutes.
Fires one Telegram alert per event (deduplicated via _pre_event_sent).
r z Pre-event alert import failed: NrS r r rA r( c < \ V3R lV 4 R4 pV' d VP R4 ' g R# VR, EF pVP R^ 4 pV^P8 d K VP RR4 pV' g K; \ SV4 pVf KM ^Tu;8: d ^#8: g M K` S RV RVP RR4 2pV\ 9 d K \ P V4 VR 8X d SR
rMSR rV' d \ V4 V , ^d, M^ p
V' d V \ V4 ,
MT p V' d R VR
RV
R
RV R
R2MRp VP RR4 p
VP RR4 p. pV
' d VP
RV
24 V' d VP
RV 24 V' d RP V4 MRp\ R\ \ V4 4 RVP RR 4 RVP R R 4 R V R V R V R!V R"V 24 \ P R#V RVP RR4 R$VR
R%24 EK R# \ d' p\ P R&T R'T 24 Rp?R# Rp?ii ; i)(c 3 V <" T F qP R 4 S8X g K Vx K R# 5ir r r s & rC r 8check_pre_event_alerts.._scan..% r, r- Nr scorerm rI r |r r r r zz = r= r r z% of threshold, r u σ away)z
z unavailabler. previouszFcst zPrev r z No consensusu ⏰ EVENT IN ~u: MIN
────────────────
?r z)
Time: u UK · Impact: z/100
u2
────────────────
z
current: zPre-event alert fired: z in r zPre-event scan failed for r )r rR rE _pre_event_sentrS r r r r r r> rU r rT rV )r r r evrJ ev_timeminsr r thz_pctgap z_contextr0 prev ctx_partsr r_ r r r s && rC _scan%check_pre_event_alerts.._scan# sw 1 HH'H$OBRVVH - -llw*2: &&, .y'B< d(b( " 1WIQrvvgb/A.BC/) ##C( ) $r #r-.A c)A%&b3q6kB ! $Ad82eC[8HT
RZ ['6 VVJ+vvj"- y''%t 5))E$.909fkk),~ 'E$K(8'9 :Ivvgc*+2bffYs.C-D E $I_UG6e I!l*YK
9 2:,awr@R?SSWX\]`WaadefW #X H KK4ZL1#F G G HsN I
I
AI
I
3I
I
+B I
I;I66I;z EURUSD pre-event scan failed: z USDJPY pre-event scan failed: ) r r r rT rU rV r rf r\ r2 rR ) r r r_ rX r r r r r s @@@rC check_pre_event_alertsrZ s
''
3I h # #M 2 9 9cD h # #M 2 9 9cD2Hj:#D)
fh :*40
fh I 5aS9:@ : 4QC899:
: 4QC899:sG B+ C D + C6CC D 'DD D:D55D:c aaa \ P R84 \ P R4 \ P 4 FH w r\ P RV RVR, RVR, R
RVR , R
R
VR , R 2 4 KJ \ P R84 ^ R
IpVP 4 ' g= \ P
RVP 4 24 \ P ! ^4 \ P RVP 4 P 24 \ F p \ V 4 K \ ^ZR7 \! 4 R oV3R lpV3R lpR pR p\# R4 P% 4 oV3R lp/ oV3R lp\& P( ! ^4 P* P- V4 \ P R4 \& P( ! 4 P. P1 R4 P- V4 \& P( ! 4 P. P1 R 4 P- V4 \& P( ! 4 P. P1 R 4 P- V4 \& P( ! 4 P. P1 R 4 P- V4 \& P( ! 4 P. P1 R 4 P- V4 \& P( ! 4 P2 P1 R 4 P- V4 \& P( ! 4 P2 P1 R!4 P- V4 R" p \& P( ! 4 P2 P1 R#4 P- V 4 R$ p
\& P( ! ^4 P* P- V
4 R% p \& P( ! ^ 4 P4 P- V 4 \ P R&4 \ P R'4 \ P R(4 \ P R)4 \ P R*4 \ P R+4 \ P R,4 \ P R-4 \7 4 ^ R
I p V P; R. R/R07 p
V
P= 4 ^ p^
p \& P> ! 4 ^ p\F PH ! ^4 K1 \ d \ P R4 EL/i ; i \@ dn pT^,
p\ P
R1T R2T 24 Y8 d: \ P
R34 \C R4T R5\E T4 R6, R724 ^ p R
p?LR
p?ii ; i)9=u* LIVE SIGNAL MONITOR v3 — EURUSD + USDJPYr u : threshold=±r
z TP=r z.2%z SL=r z hold=r
r NzMT5 init failed: zMT5 connected | terminal=u8 MetaTrader5 not installed — running in simulation mode)r c \ V 4 \ 4 R# \ d h \ d& p\ P RT RT 24 Rp?LCRp?ii ; i \ d$ p\ P
RT 24 Rp?R# Rp?ii ; i)al Run signal check for a single pair, exception-safe.
Also refreshes the account snapshot after each signal check so the
dashboard never sees more than ~15 minutes of staleness. Previously
update_account_snapshot() was only called from the legacy combined
run_signal_check() function which only ran on startup, leading to
15+ hour stale snapshots on the dashboard.
r0 z] signal_check job error: Nrn )rl rK rT rU rL rp rV )r+ r_ s & rC _safe_signal_check_pair%main.._safe_signal_check_pair st #4
(
@ # % !'%Qsyy1TF2LQC)P Q QQ
@ KK:1#> ? ? @s0
A AAAA B"B Bc < S ! R 4 R# )r NrA r^ s rC _safe_signal_check_eurusd'main.._safe_signal_check_eurusd )rB c < S ! R 4 R# )r( NrA ra s rC _safe_signal_check_usdjpy'main.._safe_signal_check_usdjpy rd rB c \ 4 R# \ d h \ d$ p \ P RT 24 Rp ? R# Rp ? ii ; i)u8 Legacy combined check — kept for startup priming only.zsignal_check job error: N)rq rK rT rU rL r_ s rC _safe_signal_check main.._safe_signal_check s2
'%Hsyy+CA3)G H HH
AAAAc \ 4 R# \ d h \ d$ p \ P R T 24 Rp ? R# Rp ? ii ; i)zrate_update job error: N)rM rK rT rU rL ri s rC _safe_rate_update main.._safe_rate_update s2
'%Gsyy+B1#)F G GGrl r c ^ < ^ RI p V3R lpV P VRR7 P 4 R# )r Nc < S ;_uu_ 4 \ P ! 4 P 4 ^8X d \ 4 M
\ 4 RRR4 R# + ' g i R# ; i) N)r rf r r r )
_summary_locks rC _run/main.._safe_daily_summary.._run s7 <<>))+q0')&( s >A A% Tr5 r r Threadr )_t2rt rs s rC _safe_daily_summary!main.._safe_daily_summary s& )
$t
,224rB c ^ < ^ RI p V3R lpV P VRR7 P 4 R# )u
Runs every 5 minutes inside the existing monitor process.
Checks:
1. State files updated recently (detects hung/frozen state)
2. Rate CSVs updated within 36h (detects data pipeline failure)
3. MT5 connection still alive (detects broker disconnect)
4. Open positions still exist in MT5 (detects orphaned state)
Sends Telegram alerts on issues — no separate process needed.
Nc ^ < \ P ! \ P 4 p \ F p\
\ V, R , , pVP
4 ' g K: V P 4 VP 4 P ,
R, pVR8 g Ky RV 2pSP V4 pVe W,
P 4 R8 g K V SV& \ P RV RVR
R 24 \ R
V R VR
R 24 K R
RRRRR/p. pVP 4 F w r\ V , p
V
P
4 ' g VP# V R24 K> V P 4 V
P 4 P ,
R, pV^$8 g K} VP# V RVR
R24 K V' dn RpSP V4 pVe W,
P 4 R8 d< V SV& \ P RV 24 \ RRP% V4 R24 ^ RIp V P) 4 ' gX R pSP V4 pVe W,
P 4 R 8 d& V SV& \ P R 4 \ R 4 ^ RIp \ EFJ p\, T, p T P R 4 ' g K* T P R!4 ' g KC T R!, p
T P/ T
R"7 pT' d Kh \
\ T, R , , pTP
4 ' d@ T P 4 TP 4 P ,
^<, pT^Z8 d K R#T R$T
2pSP T4 pTe Y,
P 4 R8 g EK T ST& \ P RT R%T
R&24 \ R'T R(T
R)24 EKM R# \* d ELji ; i \* d R# i ; i)*r& r8 r stale_state_Ni z [WATCHDOG] z state file stale (r: zh)u ⚠️ [WATCHDOG] z$ STATE FILE STALE
Last updated: zVh ago
Monitor may be running but not writing state.
Check live_monitor.log for errors.r r r r rT r+ z
(missing)r r zh old) stale_ratesz [WATCHDOG] Stale rate files: u0 ⚠️ [WATCHDOG] RATE DATA STALE
Files: r u`
FinanceFlow pipeline may have failed.
Signals continue on last known rates — monitor closely.mt5_disconnectr z&[WATCHDOG] MT5 terminal not respondingu ⚠️ [WATCHDOG] MT5 DISCONNECTED
Terminal not responding.
Attempting reconnect on next signal check.
Check open positions in MT5 manually.r r r orphan_rQ u orphaned state — ticket z not in MT5u 🔴 [WATCHDOG] z4 ORPHANED POSITION
State file says open (ticket zv)
MT5 has no matching position.
The trade was likely closed externally.
Monitor will detect this on next hourly check.)r rf r rp r) r@ rN r statst_mtimerR r= rU rV r r rW r r ry
terminal_inforT r2 r )rf r+ sfr r r r r r r rfr r r r
sf_age_min_last_watchdog_alerts rC
_run_watchdog;main.._watchdog_health_check.._run_watchdog s ,,x||,C# {4 0 >>yy{{ 2779+=+==E3; (/C/33C8D|
'A'A'Cd'J47,S1 k$7J5QT+UW$XY% 3D6 :--23K 8A B $$ !*fj&*UJ K ) / / 1 &yy{{ &&$z':; 2779+=+==E2: &&$r%F'CD 2 #+//4P AP 0/P $P = P "4P A4P 8P PP P,+P,Trv rw )_wtr r s rC _watchdog_health_check$main.._watchdog_health_check s* c L
-
5;;=rB u9 Inline watchdog enabled — health checks every 5 minutesz:01z:16z:31z:46z:02z06:00z06:05c V ^ RI p R pV P VRR7 P 4 R# )r Nc | \ 4 R# \ d$ p \ P R T 24 Rp ? R# Rp ? ii ; i)zmorning briefing error: N)r8 rT rU rL ri s rC rt 2main.._safe_morning_briefing.._run:
s* &( L399/Gs-K#L#L L
;6;Trv rw )_t3rt s rC _safe_morning_briefing$main.._safe_morning_briefing8
s& M
$t
,224rB z07:00c | \ 4 R# \ d$ p \ P R T 24 Rp ? R# Rp ? ii ; i)zpre-event alert error: N)rZ rT rU rL ri s rC _safe_pre_event_check#main.._safe_pre_event_checkA
s*
#
%Gsyy+B1#)F G GGr c V ^ RI p R pV P VRR7 P 4 R# )r Nc | \ 4 R# \ d$ p \ P R T 24 Rp ? R# Rp ? ii ; i)zTelegram poll error: N)r rT rU r ri s rC rt /main.._safe_telegram_poll.._runJ
s* ') I399/DQC-H#I#I Ir Trv rw )_tptrt s rC _safe_telegram_poll!main.._safe_telegram_pollH
s& J
4 -335rB zScheduler runninguO EURUSD signal check: every 15min (:01, :16, :31, :46) — Formula A validateduA USDJPY signal check: every hour at :02 — daily spread z-scorez Rate update daily at 06:00 UTCz% Daily Telegram summary at 06:05 UTCz3 Morning briefing daily at 07:00 UTC (London open)u@ Pre-event alerts: every 5min, 30min before score≥80 releasesz Telegram commands: polled every 30s (/add /remove /list /requestaccess /announcement /requestdashboard /grantdashboard /revokedashboard /listdashboard)c \ R R7 # )u' 🚀 MONITOR STARTED (v3 — Formula A)r )r rA rB rC r main..b
s )1Z[rB Trv zScheduler loop error #r u< Too many consecutive errors — sending alert and continuingu5 ⚠️ MONITOR WARNING
Scheduler loop error ×z
Last error: :Nd Nu.
Monitor is still running — investigate log.z<============================================================)%rU r r) r ry
initializerL r sysexitr r r rV rE r rM
__import__Lockscheduleeveryminutesdor atr secondsrq r rx r run_pendingrT r rJ rm r( )r+ r r rb rf rj rn rz r r r r
_threading_t_consecutive_errors _MAX_ERRORS _loop_errr r^ rs s @@@rC mainr d s HHVHH
9: &&( 2dV>#k*:); <8}S)c*oc-B C \*+1. / ) HHVP!~~ II)#..*:);< = HHQK ,S->->-@-E-E,FGH
4 %26 @&**I H
{+002M 5 q>f
NN1 !78HH
HI
NN U#&&'@A NN U#&&'@A NN U#&&'@A NN U#&&'@A NN U#&&'@A NNG$''(9: NNG$''(;<5
NNG$''(>?H
NN1 !676
NN2 !!"56HH
!HH
^_HH
PQHH
/0HH
45HH
BCHH
OPHH R S
# [
B HHJ
K
( ""#
1
Q P NOPx ( 1 $ II./B.C2i[Q R"1 XY ..A-B C##&y>$#7"8 9DE '(# (s, $BT6 U 6 UU W(A#WW__main__))r @rS )r @r )r X@r )r r r r )r r ))r @rS )r r r )r r r )r rT )Fr )rI rI )r )r4 ) ))z$300krS z73-85%)z$150kg ?z91-95%)z$100kg1ZGU?z92-97%)rI )Z )r ){__doc__rk r rm rO loggingr urllib.parser urllib.requestpathlibr r r r r numpyr
pandasrY r __file__resolver3 rz rJ r\ insertr) rX r r rW r@ r| r basicConfigINFO
StreamHandler FileHandler getLogger__name__rU getenvr; r< r? rD r` rq rt ru rw r rx r{ r~ r r r r r r r r r r r' r2 r3 rI r r, r6 rE rM ri r r r r r r r r r rQ rj rl rq r r r r r r r r r r r r r? r r2 rl rq rp ro r r r r r r r r r8 rM rN rE rZ r )r@ s 0rC r sp 9v
8 8 N " " $ , ,Q / y5)HHOOAs9u,-.
"("$" %" " "
& " &
" #" !" "" " " !"" ##"$ d%", 2-". E/"0 S1"2 '3"4 L**%5- !C"F
( # % "
& &
$ ! " $ "% & ' ( D) * N+ , %- . :z2/ 0 *1 2 /3 4 #5- !; IC L
F"U*W4 f
v
%
dT
*
,, 4 G&; ;gN ! 99 -1ab 99 / > ( 93 YY 324 ! %
:%
&"2H D !0FH^V *5
5A
5
)4
5A
5
D> 58(.;b( ?F2IV&P 6 \|JXFR4 )d
+Z!F#, 0
#Q"h@2a0J-*>
r)hWr
<2]<~GAT"HA B J2
hJZL^_D %,Q:hXt zF yO 6
5s M4M