o j/ @sdZddlmZmZmZddlmZddlmZddlm Z ddl m Z ddl Z ddl Z ddlZedZd efd d Zd ed ed efddZ  ddedededed ef ddZd efddZedkr~eZerxeded deddSeddSdS)u top_stocks.py Runs whenever a position closes and a slot opens up. Re-scans CURRENT market conditions (not the stale 09:25 list) to find the strongest actionable candidate right now, respecting symbol cooldowns and currently-open positions. [FEATURE 2026-08-17] The candidate pool searched here is now premarket_20 (the full morning list of 20), not final_10 -- per the project's updated intraday-scanner requirement, premarket_20 is the primary intraday universe. Ranking now uses intraday_health.py's continuous health score (via evaluate_symbol()) rather than a one-shot score_premarket_candidate() call, so the same continuously-updated health state that decides entry eligibility also decides replacement ranking -- one source of truth, not two competing scores. Symbols health.evaluate_symbol() confirms as STALE/UNHEALTHY/REMOVED are excluded from replacement selection entirely. [FEATURE 2026-08-18] Every symbol in premarket_20 -- not just the ones currently eligible to fill a slot -- gets its health recomputed and persisted every time find_replacement() runs. Previously, a symbol sitting in exclude_symbols (currently open) or on cooldown never got recomputed during a replacement search, so its state/intraday_health.json entry could go stale until the next periodic 60-second cycle even though other parts of the system (the entry shortlist ranking, the dashboard) read that same file. Now every slot-open event doubles as a full health refresh for the whole pool, and selection among the symbols that CAN fill the slot is still: highest health_score wins, total_score only breaks a tie. Writes the running result to state/top_stocks.json (write_top_stocks) so the whole system has a single canonical file of "what looks best right now," as required by the project spec. The returned candidate still must pass fast_pipeline.evaluate_fast_pipeline() before monitor.py actually buys it — this module only ranks, it never enters directly. )datetimetimezone timedelta) get_config) get_logger) get_client)score_premarket_candidateN top_stocksreturnc CsJg}|D]}||jt|jt|jt|jt|jt|jdq|S)N)tohlcv)append timestampfloatopenhighlowclosevolume)barsoutbr top_stocks.py_bars_to_dicts6s rsymbol cooldownscCsD||}|s dStdd}t|t|d}ttj|kS)NFrisksymbol_cooldown_minutes)minutes)getrr fromisoformatrnowrutc)rr tscooldown_minutesexpiresrrr_is_on_cooldown@s r+exclude_symbolscandidate_poolvolume_baselinesvolatility_baselinesc Cst}t|pg}t}t}|dur,t}|dgp$|dg}dd|D}|s5tddSt }t t j } | t|ddd } |d d } |pRi}|pVi}td t|d i} i} |D]X}||}|rwt|ddnd}t||\}}|std|d|qht||| | }t|dkrtd|dqht||||| |\}}|| |<||f| |<qh| r|| t|tdt| dt|dg}| D]\}\}}||vrqt||rtd|dqt|jstd|d|jqtdd|D}| |}|r+|j!r+t"|j!nd}|r9|j#r9t"|j#nd}t$|||t%dd|D||| ||||d}|dddshtd|d q||d!<|j&|d"<|j|d#<|j'|d$<|j(|d%<|)|q|std&dS|j*d'd(dd)|d*}|d+id,d*}|d"|krtd-|d.d/|d"d0|d1t+|dStd2td|d.d3|d#d4|d"d5|d6d7 t+||S)8a exclude_symbols: currently-open symbols, always excluded from filling the slot (but still get a fresh health refresh below -- see [FEATURE 2026-08-18]). candidate_pool: optional restricted pool; if None, defaults to state/watchlist.json's premarket_20 (falling back to final_10 only if premarket_20 is somehow empty -- e.g. a very early call before the 09:00 scan has ever written the file). [FEATURE 2026-08-18] Every symbol in the pool -- including ones currently open or on cooldown, not just the ones that could fill THIS slot -- gets a fresh intraday_health.evaluate_symbol() call and a persisted state/intraday_health.json update before any selection happens. Previously, a symbol sitting in exclude_symbols/cooldown never got its health recomputed during a replacement search (its entry in the state file could go stale until the next periodic 60-second eval cycle), even though that same file also feeds _scan_for_entries()' shortlist ranking and the dashboard. Refreshing the whole pool here means every slot-open event doubles as a full health refresh for premarket_20, not just for the symbols eligible to fill it right now. Selection itself is unchanged: among symbols that ARE eligible to fill the slot (not excluded, not on cooldown, health-eligible per that just-refreshed reading), the highest health_score wins, total_score only breaks a tie. N premarket_20final_10cSs"g|] }t|tr |dn|qS)r) isinstancedict).0rrrr os"z$find_replacement..z3[REPLACEMENT] No candidate pool available to searchintraday_healthfull_rescan_lookback_hours)hoursuniversemin_avg_daily_volumez([REPLACEMENT] Refreshing health for all z? premarket_20 symbols before selecting a fill for the open slotnamez[REPLACEMENT] z skipped: z4 skipped: insufficient bars for a fresh health checkz#[REPLACEMENT] Refreshed health for /z pool symbolsz skipped: on cooldownz skipped: health=cs|]}|dVqdS)r Nrr4rrrr z#find_replacement..csr?)rNrr@rrrrArB) daily_atr_pctflagsmeets_min_volatilityTzK skipped: below min daily ATR% (structurally low volatility, e.g. BDC/SPAC)pm_high health_score health_state price_slope vwap_slopez>[REPLACEMENT] No actionable (health-eligible) candidates foundcSs|d|dfS)NrG total_scorer)rrrrsz"find_replacement..)keyreversertradingmin_replacement_health_scorez[REPLACEMENT] Best candidate rz (health_score=z() is below min_replacement_health_score=zI -- leaving slot empty this cycle rather than filling it with a weak pickz#[REPLACEMENT] Running top_stocks.pyz selected (health=z, health_score=z, score=rK)),rset data_storeload_cooldownsload_health_stateload_watchlistr$loginforrr&rr'rlen get_assetgetattrsymbol_filterspasses_symbol_filtersdebugrget_minute_barsr6evaluate_symbolupdatesave_health_stateitemsr+is_eligible_for_entryconfirmed_statemaxget_latest_quote bid_pricer ask_pricerminrGprice_slope_classvwap_slope_classrsortwrite_top_stocks)r,r-r.r/cfgr rH watchlistclientr&startfallback_baselinehealth_updatesfreshrasset asset_nameokreasonrreadingnew_health_entryscored session_highquotebidaskresultbestrQrrrfind_replacementIs                     rcCs*t}ttj||<t|dS)N)rTrUrr&rr' isoformatsave_cooldowns)rr rrrregister_cooldownsr__main__zBest replacement: z score=rKzNo replacement candidate found.)NNNN)__doc__rrr config_loaderr logger_setupr alpaca_clientrscorerrr]r6rTrXlistrstrr3boolr+rr__name__rprintrrrrs:(        '