+ +iRt^RIt^RIt^RIt^RIt^RIHtHtHtHt^RI H t ^RI t ^RI t ^RIt] !]4P#4P$^,t]R, t]!]4] P,9d"] P,P/]!]44]R, R, t]P3RRR7]P4!]P6R R ]P8!]R , R R 7]P:!] P<4.R7]P>!R4t Rt!Rt"Rt#Rt$Rs%Rs&Rt'Rt(^4t)Rt*Rt+Rt,^t-^t.Rt/.R[Ot0^xt1^t2^R/RR0RR1RR2RR3R/t?R4R5lt@R6R7ltAR8tBR9tC]43R:R;lltDR\R<R=lltER>R?ltFR@RAltGRBRCltHRDREltIRFRGltJRHtKRIRJltLRKRLltMRMRNltNRORPltORQtPRRtQR]RSltRR]RTltSRUtTRVtURWtVRXtWRYtX]YRZ8Xd ]X!4R#R#)^u& live_signal_monitor.py ======================= Live execution signal monitor for the validated EURUSD macro lead-lag model. Runs continuously on VPS. Every hour during the London/NY session it: 1. Updates rate data from FRED and Bundesbank (auto_rates_loader.py) 2. Pulls latest 1H EURUSD bars from MT5 3. Rebuilds the lag z-score signal 4. If signal threshold breached, looks for 15M Fibonacci entry 5. If entry found and no trade open, places order with TP/stop preset 6. Monitors open trades for z-score reversal exit VALIDATED PARAMETERS (DO NOT CHANGE) -------------------------------------- Signal threshold : z-score >= 2.75 Entry : 0.786 Fibonacci pullback on 15M within 6h Take profit : 0.20% Stop loss : 0.25% Z-exit threshold : ±1.5 reversal Hold max : 52 hours Session : 08:00-17:00 EET (hours 7-16) Base risk : 0.75% ($300k notional on $100k) Signal scaling : 1x / 1.5x / 2x by z-score band Requirements ------------ pip install MetaTrader5 --break-system-packages pip install schedule --break-system-packages MT5 Setup --------- 1. Install MT5 on Windows machine or VPS 2. Enable "Allow Algo Trading" in MT5 settings 3. Enable "Allow DLL imports" in MT5 Terminal settings 4. Log in to your broker account in MT5 5. Set MT5_LOGIN, MT5_PASSWORD, MT5_SERVER in config below Place this file in: C:\Users\paul_\OneDrive\fx_macro_intraday\src\execution\live_signal_monitor.py Run from project root: python src/execution/live_signal_monitor.py Stop with Ctrl+C N)datetimetimezonedate timedeltaPathsrcdatalogsT)parentsexist_okz)%(asctime)s %(levelname)-8s %(message)sz%Y-%m-%d %H:%M:%Szlive_monitor.logutf-8encoding)levelformatdatefmthandlers live_monitoriڐ%zxIaJM$A4t2Vc5szICMarketsSC-DemoEURUSD@gx&?g{Gzd?gMb`??gQ~?i position_openFposition_ticketposition_signal entry_price entry_time position_lot last_zscorelast_signal_timestatezlive_state.jsoncB^RIp\P4pVPR4'd4\ VR,R4'dVR,P 4VR&\ P4pVPR4'd4\ VR,R4'dVR,P 4VR&W!R&\PVPV^R7RR7R# \d$p\PR T 24Rp?R#Rp?ii;i) zCPersist current STATE and ARMED to disk so it survives VPS reboots.Nr isoformat armed_time_armedindentr rzState save failed: ) jsonSTATEcopygethasattrr"ARMED STATE_FILE write_textdumps Exceptionlogwarning)r'r armed_dataes VC:\Users\Administrator\OneDrive\fx_macro_intraday\src\execution\live_signal_monitor.py save_stater6~s/zz| 88L ! !gd<.@+&N&N!%l!3!=!=!?D ZZ\ >>, ' 'GJ|4Lk,Z,Z'1,'?'I'I'KJ| $#Xdjjaj87K / )!-../s$.C0AC0AC00 D;DDc \P4'gR#^RIp^RIHpVP \P RR74pVP RR4'EdVP RR4\R&VP R4\R&VP R4\R&VP R 4\R &VP R 4\R &VP R 4\R &VP R 4pV'dVP!V4\R &\PR \R, R\R , 24\R\R, R\R , R24M\PR4VP R/4pVP RR4'EdRVP R4pV'Ed6VP!V4pVP!4V, P4R, pVR8dR\R&VP R4\R&VP R4\R&V\R&VP R4\R&\R,^8XdRMRp\RV, ^4p \PRV R\R,R R!V R" R#24\R$V R%\R,R R&V R" R'24R#\PR(VR" R)24R#R#R# \ d$p \P#R*T 24Rp ? R#Rp ? ii;i)+z Restore STATE and ARMED from disk on startup. If a position was open or signal was armed, restores both so monitoring and entry detection work correctly after restart. N)rr rrFrrrrrru)State restored — position open: ticket=z entry=uO⚠️ STATE RESTORED AFTER REBOOT Position was open at restart Ticket: z Entry: z Resuming monitoring...u5State file found — no open position, starting freshr$activer#@T direction target_price zscore_absLONGSHORTuArmed state restored —  target=.5fz | .1fzh remaining in windowu4🎯 SIGNAL RESTORED AFTER REBOOT Direction: z Target: z Time remaining: zh Fast polling resuming...z%Armed signal expired during restart (uh ago) — not restoringzState restore failed: )r-existsr'rloads read_textr*r( fromisoformatr1info send_telegramutcnow total_secondsr,roundr0r2) r'rr etr3armed_time_strr# hours_sincedir_str remainingr4s r5 load_staterQs      <2%zz*...@A 88OU + +'+xx'GE/ "'+xx0A'BE# $'+xx0A'BE# $'+xx '>E- '+xx'?E. !'+xx '>E- ,'B&.&<&>(E * *'^^L9N~%33NC '0:=LLNQUU $,0E(O,6NN;,GE+&,6NN>,JE.),6E,',6NN<,HE,'(-k(:a(?fWG %cK&7 ;IHH8  %n 5c:# )#.CEF"&&-Y/##(#8"=>++4S/:34HH !!,S 11IKL/ +8 2 ,QC0112s9AL&B)LB2LLDL6L M!L??MrTELEGRAM_TOKENz.8794831706:AAGzqHNhyvfWL2lG_kCQUupacilRf7GfNSITELEGRAM_CHAT_ID 1031071259c$V^8dQhR\/#)messagestr)rs"r5 __annotate__rZs::3:c\'d \'gR#^RIp^RIp^RIpVP 4pRVnVPVnR\ R2pR\ RVPPV4 R2pVPPWEP4RR 7pVPPV^ VR 7R# \d$p\ P#R T 24Rp?R#Rp?ii;i) z=Send a message to Telegram. Fails silently if not configured.NFzhttps://api.telegram.org/botz /sendMessagezchat_id=z&text=z&parse_mode=HTMLPOST)r method)timeoutcontextzTelegram notification failed: )rRrSurllib.request urllib.parsesslcreate_default_contextcheck_hostname CERT_NONE verify_modeparsequoterequestRequestencodeurlopenr0r1r2)rWurllibrcctxurlr reqr4s& r5rHrHs >!1!1 :((*"---n-=\J*+6&,,2D2DW2M1NN^_~~%%c f%MsB< : 4QC899:sB-C C9C44C9r8r;r<r#r=c0V^8dQhR\R\/#)rVzreturnfloat)rs"r5rZrZser[cv\FwrpYu;8:dV8gKVu#K \R,^,#)) ZSCORE_BANDS)rslohimults& r5get_multiplierr~s5$  + ,  D EsAD7&D7 D7 D7 D7($D7 &D75AD78=D77 EEc~^RIpVP4\PR4R# \dR#i;i)NzMT5 disconnected)rshutdownr1rGr0)rs r5disconnect_mt5r$s2 !  #$    s )- <<c:\P!4p\R,V8Xd\P R4R#^RIHpHp^RIpVP!R4pV'g\PR4R#\P R 4V!R VR R R 7V!RVRRR 7^RIH pH pH pV!RVVRR7V!RVVRR7V\R&\P R4R# \d$p\PRT 24Rp?R#Rp?ii;i)u| Updates US and DE yield data from FRED and Bundesbank. Only runs once per calendar day — skips if already updated today. ru,Rate data already updated today — skippingT)update_local_csvfetch_fred_seriesN FRED_API_KEYu-FRED_API_KEY not set — skipping rate updateFz*Updating rate data from FRED/Bundesbank...us2y.csvDGS2us2y) series_idvalue_col_name us10y.csvDGS10us10y)fetch_bundesbank_seriesBUNDESBANK_DE2Y_CSVBUNDESBANK_DE10Y_CSVde2y.csvde2y)csv_urlr de10y.csvde10yzRate data updated successfullyzRate update failed: )rtodayLAST_RATE_UPDATEr1rGingestion.auto_rates_loaderrrosgetenvr2rrrr0r) rrrrapi_keyrrrr4s r5update_rate_datar.s JJLE5( ?@S))N+ KKG H =>&76(. 0&77(/ 1   %r[c ^RIpVP\\^V4pVe\ V4^8Xd)\ P RVP4 24R#\P!V4p\P!VR,RR7VR&VPRRRRR R R R /R 7pV.RO,pVPR4PR R 7# \d$p\ P RT 24Rp?R#Rp?ii;i)z:Pulls recent 15M EURUSD bars from MT5 for entry detection.NzFailed to get 15M bars: rrrrrrrrrTrzget_mt5_bars_15m error: )rrrrr)rrrrrr1rrrrrrrrr0rs& r5get_mt5_bars_15mrns!'' q&I =CJ!O II01A0BC D \\% 6 =: YY!&w AYB < =~~j)5545@@  ,QC01sACA=C D 'DD cfV^8dQhR\PR\PR,/#)rV prices_1hrtN)rr)rs"r5rZrZs+GG2<<GBLL44GGr[c ~ aa ^RIHp^RIHp\R, R, R, oVP 4pVR,P P4VR&VPRRR 7PR4R 7PR4PR R 7pVR ,P4VR&\P!VR,4VR&V3RlpV!RR4pV!RR4pV!RR4pV!RR4pVR,P4p VR,P!4p \P"!R\P$!WRR7/4o V 3Rlp V !VR4p V !VR4p V !VR4pV !VR4pV P'V RR7P'VRR7P'VRR7pVR,VR,, VR&VR,VR,, VR&VR,P)^4VR&VR,P)^4VR&V.R5O,P+4pVP'VRR R!7P+RR.R"7p\-V4\.^,8dE\0P3R#\-V4 R$\.^ , 24VR,R6,VR%&EM^\-V4p\4P6!V\4P84p\4P6!V\4P84p\;\.V4EFpVP<V\., VP 4pVVR,P?4^8VR,P?4^8,,p\-V4^8dK~VPAVRR.,4pVPCVR,V4PE4pVPFPIR\4P84VV&VPFPIR\4P84VV&EK VVR&&VVR'&VR&,PM\NR(7PQ4PS^4PUR7R)4VR*&VR',PM\NR(7PQ4PS^4PUR8R+4VR,&VR*,VR,,VR,,VR,,,VR%&V.R9O,P 4pVP'VRR R!7p.R:OpVV,PW4VV&VR ,P^4VR-&VR%,VR-,, VR.&VR.,PY\Z\ZR/7PQ4pVR.,PY\Z\ZR/7P]4pVR.,V, V, VR0&VP+R0.R"7PR R 7p\0P_R1\-V4 R224V# \JdEKIi;i \Jd8p\0PaR3T 24^RI1pTPe4Rp?R#Rp?ii;i);u Rebuilds the lag z-score signal purely from live MT5 1H bars and the rate CSV files on disk (updated daily by update_rate_data). Does NOT load any historical price CSVs — uses only the 500 bars pulled from MT5 (covering ~21 trading days which is enough for the 60-bar z-score window and the 24h return lookback). Rolling beta is computed inline from the MT5 price data and the current rate spread files. Nrr rawrrrF)as_indexr)rTreurusd_return_1dc<SV, pVP4'g\RV 24h\P!VR.R7pVPUu.uFqDP 4NK upVn\P !VR,4VR&\P!W1,RR7W1&VRV.,P4PR4#uupi)zRate file not found: r) parse_datescoerce)errors) rCFileNotFoundErrorrread_csvrlowerr to_numericdropnar)fnamecolpathrc RATES_DIRs&& r5 load_rate&compute_live_zscore..load_ratesu$D;;=='*?v(FGGTx8B-/ZZ8Z'')Z8BJ6 3BvJmmBGH=BGvsm$++-99&A A9sCrrrrrrrrD)freqc <SP4pVP4pVR,PR4VR&VR,PR4VR&\P!VP R4VP R4RRR7#)rzdatetime64[us]backward)onr;)r)astyper merge_asofr)rate_dfrleftright date_ranges&& r5ffill_to_daily+compute_live_zscore..ffill_to_dailysOO%DLLNE L//0@ADL!&M001ABE&M==!1!1&!9"'"3"3F";%+zC Cr[)r spread_2y spread_10yspread_2y_change_1dspread_10y_change_1dr)rhow)subsetz"Insufficient data for beta model: z days, need predicted_return_1d beta_2y_raw beta_10y_raw)spang?beta_2yg{Gz?beta_10yeurusd_return_24h lag_gap_24h) min_periodslag_zscore_24hzSignal built from z5 days MT5 data + live rates (no CSV price dependency)zcompute_live_zscore error: )rlast)rrrgQgg{Gz)rrrr)rrr)3statsmodels.apiapipathlibr BASE_PATHr)dt normalizegroupbyaggrr pct_changerrminmaxrrmergediffrr BETA_WINDOWr1r2npfullnanrangeilocabs add_constantOLSfitparamsr*r0ewm SMOOTH_SPANmeanshiftclipffillrolling ZSCORE_WINDOWstdrGr traceback print_exc)!rsmrdaily_pxrrrrrdate_mindate_maxrus2y_dus10y_dde2y_dde10y_dspreadsmodel_dfnb2y_rawb10y_rawisampleXresr fill_colslag_meanlag_stdr4r/rrs!& @@r5compute_live_zscorerEs {$ &.8 NN$ %j144>>@ &   fu  5 S(S ) [ [d[ #  (0'8'C'C'E#$>>(6*:; B*v.+w/*v.+w/F#'')F#'')\\62==RU+V"WX  C!/ 0 / 0,,w6,288F8KQQRY^dQe '76? B  ' 0773C C *1+*>*C*CA*F%&*1,*?*D*DQ*G&'QRYY[>>'f&>AHH&(=>I@ x=;? * KK(=!>!B!B!Dq!H"()?"@"D"D"F"J!LMv;#OOF,ACY+Z$[\&&(:!;Q?CCEC"%**..1F"PGAJ"%**..1G"PHQK+(/H] #'/H^ $#+M#:#>#>K#>#P#U#U#W#]#]^_#`#e#efkmq#rHY #+N#;#?#?[#?#Q#V#V#X#^#^_`#a#f#fglnr#sHZ #x0E'FF$x0F'GGH * + MNNRdf __X&f_ =Z 9 ++-9 #%W+"8"8"< "$%:";bAT>U"U=m$,,] ,V[[]m$,,] ,VZZ\ "= 1H <G  YY/0Y 1 = =4 = H %c(m_4ijk ?!B  /s34 s>OY:BY'HY:' Y72Y:6Y77Y:: Z<,Z77Z<c0V^8dQhR\R\/#)rVr=rtru)rs"r5rZrZs4454U4r[c ^RIpVP4pVfR#VPp\V4pV\,V,p\ R, pVP \4pVfRpMVP^ ,pWVV,, p V'd VPMRp V'd VPMRp V'd VPMRp \V \W44p \W, 4V ,p \P!RV R RVR R V R VR 24V # \"d$p \P%R T 24Rp ? R#Rp ? ii;i)aP Calculates MT5 lot size for the given z-score and account balance. Formula: risk_dollar = balance * BASE_RISK_PCT * multiplier stop_dollars = lot_size * pip_value_per_lot * stop_pips lot_size = risk_dollar / (stop_pips * pip_value_per_lot) For EURUSD standard lot: pip_value_per_lot = $10 per pip (on $100k notional) N{Gz?g-C6?g$@gY@zPosition size: .2fz lots | Risk: $z,.0fz | Multiplier: zx | Balance: $rzcalculate_lot_size error: )rrrr~ BASE_RISK_PCTSTOP_PCT symbol_infortrade_tick_value volume_min volume_max volume_steprrrKr1rGr0r)r=raccountr multiplier risk_dollar stop_pipsrLpip_value_per_lotlot_sizemin_lotmax_lotlot_stepr4s& r5calculate_lot_sizerZsE(!##% ?__#J/ },z9 & oof-   $  + < II23>>3C2DE F >>S33 3 II.v~~.>?!!' 02 3 ?#QYEF32S>%5#heBs8,!<<. * + ||  's+,sC:I>I>I>,I> .I>:D,I>(A I>4A I>> J, J''J,c<V^8dQhR\R\R\/#)rVticketreasonrt)rrYr)rs"r5rZrZs!22#2s2t2r[cr^RIpVPVR7pV'g\PRV R24R#V^,pVP \ 4pVf\P R4R#VP^8XdVPpVPpMVPpVPpRVPR \ R VPR VR VR VR^RRRRV 2RVPRVP/ pVP!V4p V eV P"VP$8wd/\P RV 'd V P"MR 24R#VP&p \P)RV RV RV R 24R# \*d$p \P RT 24Rp ? R#Rp ? ii;i)z(Closes an open position at market price.N)rz Position u$ not found — may already be closedTzFailed to get tick for closeFr_r`rrapositionrbrerfrgrhzclose: rirjzClose failed: NonezPOSITION CLOSED | Ticket=z | Reason=z | P&L=$rIzclose_position_market error: )r positions_getr1r2rorrrarsrtrprqrurrvrwrxryrzprofitrGr0) rrrrposr| close_type close_pricerjr~pnlr4s && r5close_position_marketrs0!$$F$3 KK)F8+OP Qqk##F+ < II4 5 88q=--J((K,,J((K C11 F CJJ J F K B H gfX. C.. C11  ( >V^^s/E/EE IIv~~V&LM Njj ,VH5!((3s)5 6  1!56s4FF7F4CFF+F F6F11F6c$V^8dQhR\/#rr)rs"r5rZrZstr[c^RIpVP\RR7pVRJ;'d\V4^8# \dR#i;i)z,Checks if our position is still open in MT5.Nrg)r`rfF)rrrrr0)r positionss r5check_position_statusrsM!%%V8%D $;;Y!);; s%77 AAc^RIpVP\4pVfR#VPVP3# \ dR#i;i)z&Returns (bid, ask) from MT5 tick data.N)rrorrtrqr0)rr|s r5get_live_pricersG!##F+ <$((## s99 AAc<V^8dQhR\R\R\/#)rVr;r<r=r])rs"r5rZrZs!5er[c >R\R&V\R&V\R&\P!\P4\R&V\R&V^8XdRMRp\ P R V R VR R VR R24\4\RV RVR RVR R24R#)z Arms the fast-polling execution engine. Called when z-score threshold is breached. Script polls every 5 seconds for the 0.786 level to be touched. Tr8r;r<r#r=r>r?zARMED | | Target=rA | z=.3fz | Polling every 5s for up to 6hu'🎯 SIGNAL ARMED Direction: z Z-score: z Fib 0.786 target: z Watching every 5s for up to 6hN) r,rnowrutcr1rGr6rH)r;r<r= dir_labels&&& r5arm_fast_pollingrs !E(O%E+(E.$LL6E,&E,#q.gIHHx {*\#,>?S!!ACDL " $s#$)#./) *r[c$V^8dQhR\/#)rVrrX)rs"r5rZrZsr[cR\R&R\R&R\R&R\R&R\R&\PRV 24\4R#) z Disarms the fast-polling engine.Fr8Nr;r<r#r=zDISARMED | Reason: )r,r1rGr6)rs&r5disarm_fast_pollingrsL!E(O E+ E. E, E,HH"6( +,Lr[c$V^8dQhR\/#rr)rs"r5rZrZsyytyr[cJ\R,'gR#\R,'dW\4pV'gC\P R4R\R&R\R&R\R&R\R&R\R &R#\ P !\P4pV\R ,, P4R , pVR 8d(\P R VR R24\R4R#\4pVfR#VwrE\R,p\R,p\\R4'g ^\n\;P^, un\P^,^8XdM\P RVR RVR RVR RVR;8XdRMR RV^8XdWW8:gVR;8Xd WG8dRMR 2 4V^8XdWW8*pTp MWG8pTp V'gR#V^<,p \P RV^8XdRMR RV R R VR R!V R" R#2 4\R$V^8XdRMR R%V R R&VR R'V R" R(2 4\R),p \!V 4p V R*8d#\P#R+4\R,4R#\%VV V V R-7p V eR.\R&V \R&V\R&V \R&VP'RR/7\R &V \R0&\R14\)4V^8XdRMRpV^8XdV ^\*,,MV ^\*, ,pV^8XdV ^\,, ,MV ^\,,,p\R2V R3V R R4V R5 R6VR R7VR R8V 2 4R.#\P#R94\R:4R#)z hit=YESNOz TARGET HIT | z | Price=rz | Elapsed=.0fzm since signalu#✅ ENTRY HIT Direction: z Price: z Target was: z Time since signal: z minutes Placing order now...r=rHuLot size too small — skippingzlot size error)r\rrVr=Ttzinforz order placedu'📈 ORDER PLACED Direction: z Entry: z Lots: rIz TP: z SL: z Ticket: z#Order placement failed in fast pollz order failedry)r,r(rr1rGrrrrrJrrr+ run_fast_pollrrHrZrrreplacer6rrrK) still_openr elapsed_hourspricesrtrqr;target entry_hit exec_price elapsed_minr=rVrrOtp_pricesl_prices r5rrs ?? _*,  HH\ ]',E/ "'+E# $'+E# $'+E- '+E,  ,,x|| $C5..==?$FM )-)<"+Q,3;IrMVYVahlmo p A~]  ]   "$KHH}y!|VAB %Zs|<#C(89 #,a<W=>S!"cl#)#./  |$J#J/H$ 34,-  F#'o#) #, #-m#&;;d;#;l#+nN+ %qL&g,5qL:qx(j!F(>S.7l:qz* AhJ@W$I& %&cN#C.!C.!h    78N+r[c$V^8dQhR\/#rr)rs"r5rZrZs<\R/,p V ^8Xd V\8)8:gV RI8XdV\88d \?R04R#V\08d^MRIp V ^8XdR1MR2p R3VP@9d\/VR3,4M"\/VP,RI,R3,4p \/VP,RI,R4,4p \/VP,RI,R5,4p\P R6VP,RI,R7,R* R8V R* R9VR* R:V R* 24V ^8XdAW, pVR;8:d\P RVR* R=24R#V \BV,,p\R,'g5\P R?V R@VR 24\EV V\=V44R#\R/,V 8wd@\P RAV R@VR 24\?RB4\EV V\=V44R#\RC,pV\RC&\=V4\RD&\P REV RFVR* RGVR* R@VR RH2 4R#)JzU Main function called every hour. Checks for new signals and manages open positions. u─── Signal check at z%Y-%m-%d %H:%M UTCu ───ru<Outside trading session — position open, monitoring z-exitr8u$Outside trading session — skippingNuDOutside trading session — but armed, continuing to watch for entryu*MT5 not connected — attempting reconnectu*Failed to reconnect MT5 — skipping checkz*Position closed by broker (TP or stop hit)Frrrrz+Insufficient 1H bars for signal computationzSignal computation failedr rzCurrent z-score: ru (threshold ±)rr9zHold limit reached (rBuh) — closing time_limitzZ-score reversal detected: z <= -u (was long) — closing positionu)⚠️ Z-EXIT Z-score reversed to z Closing LONG positionzscore_reversalz >= +u! (was short) — closing positionzPosition open | Ticket=z | Entry=rAz | Z-score=u — holdingzNo signal (|z|=z < r;zz-score reversed before entryr>r?rrrzSignal bar: O=rz H=z L=z C=g-C6 ?z#Pullback range too small for long (u) — skippingz$Pullback range too small for short (zSIGNAL DETECTED | ru(Signal direction changed — rearming | zdirection changer<r=zAlready armed | z | Target updated: u → z | Fast polling activery)#rrrrr1rGstrftimerr(r,rrr2rrrrrr-rrEemptyr rv THRESHOLDrrJr ZSCORE_EXITrHr!rindexFIBr)rrrbars_1h signal_dflatest current_z signal_dir hours_held armed_dirsignal_directionr signal_close signal_high signal_lowpullback_ranger< old_targets r5run_signal_checkrs ,,x|| $CHH)#,,7K*L)MZ XY     ! ! HHS Tx HH; <  HH[ \ >>   @A}} IIB C  _*,  HHA B',E/ "'+E# $'+E# $'+E- '+E,  G#g,)DD ?@$G,IIOOO -. ^^B Ff-./I$E-HH 30&Kq*+ _%(9":"F,-    *++T+2|,-.;moEJR/ 3/?~NO%e,=&> M+0o&+/'( !O k\ 9 HH29S/{mT78 9 ''0o6()  "%(9":#"6c)AFG ??k*IQI+$=R[_aRafotf#$CD%2q*a/WI.5 -D5)%PWP\P\]_P`ahPiJjLb)&12Kb)%01JHH~gll2.v6s;3{3>OPS!\#$6891%2 W $ HH:>#:Nn] ^ #cN&:: $3 W $ HH;N3;O~^ _ #cN&::  ?? %i[i_EF)<YH { / / ;I;eIVY?[\./)<YH>* ,n #Il #I;.As#5c(:;_$:< =r[cT^RIp\PR, p.pVP4'd"VP VP RR74pVP RVRVRVRVR \V^4R \P!4P4/4VPVPV^R 7RR7\PR \V4 R \!RV44R 24R# \"d$p\P%RT 24Rp?R#Rp?ii;i)zDAppend closed trade to trade_history.json for dashboard consumption.Ntrade_history.jsonr rrrr;rVnet_pnl closed_atr%zTrade history saved: z trades, total PnL=$c32"TF qR,xK R#5irN.0ts& r5 %save_trade_history..;s"@AY<<rIzTrade history save failed: )r'r-parentrCrDrEappendrKrrr"r.r/r1rGrsumr0r2) rrr;rVrr' history_pathtradesr4s &&&&& r5save_trade_historyr)s7!((+??     ZZ 6 6 6 HIF 6 ; 9 8 5!, 8<<>335     6! #_outlook_fallback..hs' r[T)keyreverserdayeventsNNprob top_event No key events)MonTueWedThuFri)z 2026-02-19z 2026-04-09z 2026-05-21z 2026-06-18z 2026-07-09z 2026-10-08z 2026-11-19z 2026-12-31) z 2026-01-30z 2026-03-06z 2026-04-17z 2026-05-06z 2026-06-05z 2026-07-16z 2026-09-10z 2026-10-22z 2026-12-03) rrrweekdayr!rrstrptimerr sortedrr)rrmondayrTdistzp FOMC_MINUTES ECB_MEETINGSr~r>rd_objevstopeprs& r5rrQs \\^C 9#++-0 0F ,D A Y D7Rd3h$s(BdSVhaefiai\]opBILVL F 1X)++55jA!!$ 3  W5KIVZ[bce,f!g  W5HSWX_`b,c!d eii  W5MiX\]deg,h!i ==?A !UYY"2"2 JJ 6ygbQ RS2DA"%s1vg13s72:r"(+s3rw<$ vd5#b'&#sCF7OQ R Mr[c~R\V^ , 4,R^ \V^ , 4, ,,#)u█u░)rKps&r5 _prob_barr&qs*uQrT{*5"U1R4[.+AAAr[c*V^<8dR#V^#8dR#R#)<u🟢u🟡u⚪rr$s&r5 _prob_emojir)rsQU6J!R%JUJr[caV'gR#V'EdY\VRR7p.R!OpVFpVR,VR,8XdVR,^8dRMRpVR,'d'RPR VR,R ,44MR p\VR,4R ,VR ,,R,\VR,4,R,\ VR,4,R,V,R,V,pVP V4K VRRVR ,,R,\VR,4,R,., pRPV4#\ V3RlV4R4p V 'gR#V R,'d(RPRV R,R,44pMRpRV R ,,R,\V R,4,R,\V R,4,R,\ V R,4,R,V,R ,#)"cVR,#)rrrs&r5r(_build_outlook_section..xs1V9r[)r0────────────────rru⭐r z, c32"TF qR,xK R#5i)rNrrr4s& r5r)_build_outlook_section..|sAAwZZr:NrVNrz r z z%  u └ u⭐ Best day: z at % c3F<"TFqR,S8XgKVxK R#5i)rNr)rd today_strs& r5rr1s@g6i)?11gs! !Nc3z"TF1pRVR,,R,VR,,R,xK3 R#5i)u • rz (rrNrr0s& r5rr1s2m\lWXMAgJ6=) LsRR\ls9;r u! • No key macro events todayu$ 📅 TODAY'S SIGNAL OUTLOOK — u6 ──────────────── z Signal probability: z% z Key events: u1 ────────────────)r+u)📅 WEEK AHEAD — SIGNAL OUTLOOKr.)rjoinr)rYr&rnext) outlook is_mondayr7bestlinesr6starr rowtds &&f r5_build_outlook_sectionrBts& yG!45uAfIf5!F)b.5bDEFx[[499A8RAAVeC& *V3ah>I& N#%*+-6qy-ABDGHJNO#$&)*C LL   DF\_cdi_jFjmwFwz}CDJK{LGLORGRS Syy @g@$ G h<<))m\^_g\hik\lmmC8C .s;Fq llFrru—rz% of thresholdr+rrr>r?u🔵 z @ rAu 🔵 Openu⚪ No positionz+$rz-$ruW📊 DAILY SUMMARY ──────────────── Z-score: z (z ) Position: z Trades: z | PnL: uZ System: ✅ Running ──────────────── Threshold needed: ±)r(r*r'r-rrCrDrErrr0r!rrrrrrrvrBrH)rpos_open trade_count pnl_totalr'rrz_strz_pctentry_px entry_dirrOpos_strpnl_strr7r<r; outlook_texts r5send_daily_summaryrQs=)I?E2HKI !((+??    ZZ 6 6 6 HIFf+K;F;;I$-#8 #eEDMIy(,S1 @SUEIIm,II/0 '1nF':BeG9C~6 #'0A~9T"#RIt?T;UG '' 3I &&(A-I/inn10EF-gyL  gWUG,I-z'3 )k .  1    *  s/0G">GG0"G0 G-,G-0 H?Hc  \PR<4\PR4\PR\ 24\PR\ 24\PR\R R\ R 24\PR\ 24\PR\R 24\PR \ R \^, R 24\PR<4\4'g\PR 4R #\4\PR4\4\4\P !4P"P%R4P'\4\P !4P(P%R4P'\4\P !4P(P%R4P'\*4\PR4\PR4\PR4\,P/R4pVeVR MRp\1R\ R\ R\^, RV R2 4\2P2!4p\P4!4\2P2!4V, ^<8d \74\2P2!4p\,R,'Ed\94pV'Eg\PR4\,P/R4p\,P/R 4;'g^p\,P/R!4;'g^p\,P/R"4;'g^pR#p^R Ip ^R$IHp \<P@!V PB4PE^^^R%7\GR&4PI^R'7, p V PKV \<P@!V PB44p V 'Ed.^R I&p V PN!\QV 4V ^,PS4PU4R(7pV'd/VVR),\WV48HVR*,^8H,,pMV PN!4pVPX'd4VVR+,R,8HVR*,^8H,,P[^4pVPX'gL\]VP^R=,R-,4\]VP^R=,R.,4,p\1R0T R1T^8dR2MR3 R4TR5 R624\eYETYx4R7\,R&R \,R&R \,R!&R \,R &R \,R8&\74\fR9,'d$\i4\2Pj!^4EKb\2Pj!^4EK{ \`d#p\PcR/T 24R p?LR p?ii;i \ld\PR:4Mi;i\o4\PR;4R # \o4\PR;4i;i)>=zLIVE SIGNAL MONITOR STARTINGz Symbol : uThreshold : z-score ±z TP : z.2%z | Stop: uZ-exit : ±z Risk : z Session : z:00 - z:00 EETuACould not connect to MT5 — check credentials and MT5 is runningNz#Running startup rate data update...z:01z06:00z06:05z3Scheduler running. Signal checks every hour at :01.z5Rate data updates: at startup and daily at 06:00 UTC.zPress Ctrl+C to stop.rrz computing...u?🟢 LIVE MONITOR STARTED Symbol: EURUSD Threshold: z ±z Session: z:00-z:00 EET Current z-score: z Watching for signals...ru3Position closed by MT5 (TP or stop) — state resetrrrrrD)r)rminutesecondrrr position_identryrfrgrswapzP&L lookup failed: u$🔔 POSITION CLOSED Ticket: z Net P&L: +r+$rIz Closed by MT5 (TP or SL hit)Frr8zShutdown requested by userzLive signal monitor stoppedz<============================================================ry)8r1rGrrrrrKrrJrrrrrQrrscheduleeveryratdor rQr(r*rHr run_pendingr6rrrrrrr __import__rhistory_deals_getpandasrlist_asdictkeysrrtailrvr r0r2rr,rsleepKeyboardInterruptr) startup_zrJlast_state_saverrrLrMrVrrrfrom_dtdealsrrmatchr4s r5mainrns9HHXHH +,HH|F8 $%HH%i[ 12HH|F3<{8C. ABHH~k] +,HH|M#. /0HH|-.f_Q5F4Gw OPHHX == UVLHH 23 NNU#&&'78 NNG$''(89 NNG$''(:;HH BCHH DEHH $% -(I"+"7yo^E #%%&d?1+<*=>!7#"  #S0))+  "yy{_,2 "&))+ _%%24 !zHHRS % *; >QH"G?15"*,,x||"<"D"D!"1Q#E#8&z2<>?2 / -./  ./  ./s~(A>Y('AY(Y(Y(>Y(D1X86AX8;A X8A5Y(<rs-^ 88  N " " $ , ,Q /  x= HHOOCM" f v % dT * \\ 8 G&887Kcjj) '  !           utttttt  ' ),= = t4/$D2ND>99-1ab99/>:( edddd  D 'T#*,,GV4pJZ2j 2yz<Y=z74 ,@BJ B1hF0R zFr[