Files
resonance-engine/__pycache__/inject_variable_isolation.cpython-312.pyc
T

220 lines
25 KiB
Plaintext
Raw Normal View History

2026-06-06 21:34:30 +07:00
Ë
])$jQãóødZddlmZddlZddlZddlZddlZddlmZddl m
Z
ddl Z ddl
ZddlmZddlZdZdZgd¢Zgd ¢Zd
Zgd ¢Zd Zd
ZdZdZdZdZdZdZ dZ!dZ"dZ#dZ$dZ%dZ&dZ'dZ(dZ)gd¢Z*ejVd«Z,e
de,«Z-e-j]dd¬«e-d z Z/e-d!z Z0d.d"„Z1Gd#„d$«Z2d/d%„Z3d0d&„Z4 d1 d2d'„Z5d3d(„Z6 d4d)„Z7d5d*„Z8 d6d+„Z9d,„Z:e;d-k(re:«yy)7uIinject_variable_isolation.py — per-variable signal characterisation instrument.
This is the experiment Claude Desktop specified, with two physical-coherence fixes:
1. Equal strength + same location = 6 identical injections with different labels.
So strength is derived from each variable's own distribution at fixed
quantiles (p99, p50, p01). "Characterise variable" then means: when this
database column says an extreme reading, how much energy does it naturally
deliver, and what's the lattice response shape?
2. Calibration runs added: raw +/- 0.5, 0.25, 0.1 with no variable identity.
This is the lattice's raw impulse response curve. Every variable response
is compared against it. If mid_price's p99 response matches a raw +/-0.05
calibration scaled, mid_price has no special signature beyond amplitude.
Baseline: stability-based (verified low-variance plateau), NOT the engineered
12.0-13.0 band. The lattice is parked at the asym=33 plateau due to accumulated
forcing; we can't reach 12.x without a daemon restart (RESONANCE-owned, forbidden).
What matters: clean steady state, whatever the level, with known sigma.
Output: /mnt/d/Resonance_Engine/traj/varisol_<RUN_ID>/
meta.json
baseline_clean_stats.json
injections.jsonl (one record per injection, see below)
progress.log
é)Ú annotationsN)Údeque)ÚPathz4/mnt/d/PaperTrader/research/hl_data/minutes/20260601ÚBTC)Úsigned_flow_usdÚwallet_entropyÚ
vwap_driftÚ trade_countÚlarge_print_cntÚ mid_price)g{®Gáz„?çà?g®Gáz®ï?ç333333Ó?)gà¿gпgš™™™™™¹¿gš™™™™™¹?gÐ?r
éig333333ã?g{®Gázt?i`TiXi,gš™™™™™é?gø?éé(g€@g@@ztcp://127.0.0.1:5556ztcp://127.0.0.1:5557) Ú asymmetryÚ coherenceÚ stress_xxÚ stress_yyÚ stress_xyÚvorticity_meanÚvel_meanÚvel_maxÚvel_varz
%Y%m%dT%H%M%Sz%/mnt/d/Resonance_Engine/traj/varisol_T)ÚparentsÚexist_okz progress.logzinjections.jsonlcóÐdtjd«d|}t|d¬«tj d«5}|j |dz«ddd«y#1swYyxYw)%Y-%m-%dT%H:%M:%Sz] T)ÚflushÚ
)ÚtimeÚstrftimeÚprintÚPROGRESSÚopenÚwrite)ÚmsgÚlineÚfs ú4/mnt/d/Resonance_Engine/inject_variable_isolation.pyÚlogr-bs\Ø
Œt}‰}Ð2°"°S°EÐ :€DÜ ˆ$Ü ð˜qØ t‘ Ô÷÷ñús ¾AÁA%có(eZdZddZdZddZdZy)ÚTelSubcóXtjj«|_|jj tj
«|_|j j|«|j jtjd«|j jtjd«td¬«|_ tj«|_tj |j"d¬«|_|j$j'«y)iˆi')ÚmaxlenT)ÚtargetÚdaemon)ÚzmqÚContextÚinstanceÚctxÚsocketÚSUBÚsockÚconnectÚ
setsockoptÚ SUBSCRIBEÚRCVHWMrÚbufÚ threadingÚEventÚ_stopÚThreadÚ_runÚ_tÚstart)ÚselfÚaddrs r,Ú__init__zTelSub.__init__kÜ—;;×)ˆŒØ—H‘H—O‘O¤C§G¡GÓŒ Ø ‰ ×ј$ÔØ ‰ ×ÑœSŸ]™]¨CÔ ‰ ×ÑœSŸZ™Z¨Ô uԌܗ_‘_Ó&ˆŒ
Ü×"¨$¯)©)¸AˆŒØ 
r1cóÎ|jj«|jjd«rp|jj t
j «}tj|«}tj«|d<|jj|«|jj«sŒ§yy#t
j$rYŒØt$rYŒâwxYw)NéÈÚ
_recv_wall)rCÚis_setr;ÚpollÚ recv_stringr5ÚNOBLOCKÚjsonÚloadsr#r@ÚappendÚAgainÚ Exception)rHÚrawr)s r,rEz TelSub._runvØ—**×
Ø—99—>> Ÿ)™)×/´· ± Ó<Ÿ*™* S/CÜ(,¯ © « C˜ Ñ—HH—O‘O CÔ
—*‘*×%øô—9‘9ò
ÙÜò
Ùð
úsœB CÃC$ÃC$Ã#C$có~t|j«Dcgc]}|jdd«|k\sŒ|Œc}Scc}w)NrMr)Úlistr@Úget)rHÚt0Úms r,Úsincez TelSub.sinceƒs0Ü §¡Ja¨Q¯U©U°<ÀÓ-CÀrÓ-IÒJùÒJs˜:³:có8|jj«y)N)rCÚset)rHs r,Ústopz TelSub.stop†sØ
Õr1N)rIÚstr)r[ÚfloatÚreturnú
list[dict])Ú__name__Ú
__module__Ú __qualname__rJrEr]r`©r1r,r/r/jsó ò óKór1r/c
óØttjttt«dz «««}|st dt«|Dcgc]}t
j|«Œ}}t
j|d¬«}||jtk(jd«jd¬«}tdt|«dtd t|«d
«|Scc}w) Nz *.parquetzno parquet files in T)Ú ignore_indexÚminute)Údropzloaded z minutes of z data from z parquet shards)ÚsortedÚglobrarÚ DATA_DAY_WSLÚ RuntimeErrorÚpdÚ read_parquetÚconcatÚcoinÚCOINÚ sort_valuesÚ reset_indexr-Úlen)Úfilesr+ÚdfsÚdfs r,Ú load_btc_dayr|Ü ”4—9‘9œS¤¤lÓ!3°kÑ!AÓ D€EÙ ÜÐ1´ÐAØ',Ö
- !Œ2?‰?˜ Ð
-€CÐ
3 TÔ *€BØ ˆBG‰G”t‰OÑ × (Ñ (¨Ó 2× >Ñ >ÀDÐ >Ó I€B܈'”#b“'˜,¤t f¨K¼¸
°|À?Ð
€Iùò .sÁC'cóª||jt«}t|j««}t|j««}i}tD]}}t|j |««}|dk(rd}n4||z
|z } tt
j| dd««}
|
dz tz}dt|dz«d} |||||dkDr
nd|dœ|| <Œ|S) zËFor this var, find the value at each quantile, convert to strength
via z-score / 3 * STR_CAP (consistent with v1/v3 encoding so cross-experiment
comparisons are valid). Returns {label: strength}.rçgÀgqédÚ02d)ÚquantileÚ raw_valueÚmeanÚstdÚ z_clippedÚstrength)
Úastyperbr„r…Ú QUANTILESrÚnpÚclipÚSTR_CAPÚint) r{ÚvarÚmuÚsdÚoutrÚvalr‡Úz_clipÚlabels r,Úquantile_strengthsr—ð ˆ3‰”uÓ€AÜ ˆqv‰v‹x‹€BÜ ˆqu‰uw‹€BØ
€CÜ
ò
ˆÜA—JJ˜q“MÓ"ˆØ
Š7؉Hàr‘˜R‘ˆAÜœ2Ÿ7™7 1 d¨CÓ1ˆFØ  ¬Ñ/ˆHØ”C˜˜#™“J˜sÐàØØØØ#%¨¢6™¨sØ ñ

ˆˆ
ð
ð" €Jr1cóÜtj«}d} tj«}
|
|z
|kDrtd|d|
|z
dd«y|j|
|z
«} t| «dkrtjd«Œlt j | D cgc]} | d Œ c} «}
t j | D cgc]} | d
Œ c} «}t|j««}t|j««}|
|
d z
}|d d kDr#tt j||d
«d «nd}||kxrt|«|k}|||xrt||z
«|k}|r,td|d|dd|dd|dd|
|z
dd «||||
|z
dœS|
| z
dkDr3d}| d||z
d}td|d|dd|dd|dd|
|z
dd| «|
} tjd«ŒÌcc} wcc} w)zÈWait until the asym signal is stable over `probe_s` window.
Returns dict with baseline stats, or None on timeout.
If anchor_mean+anchor_tol given, also requires |current_mean - anchor| <= tol.r~z TIMEOUT: z after z.0frérMrréÿÿÿÿéú u STABLE — asym mean=ú.3fú std=z slope=ú+.5fz
/s waited=)Ú asym_meanÚasym_stdÚasym_slope_per_sÚwait_sé<Úz delta_anchor=z+.2fz not stable: asym mean=é
) r#r-r]rxÚsleeprŠÚarrayrbr„r…ÚpolyfitÚabs)ÚtelÚprobe_sÚ
std_threshÚ slope_threshÚ timeout_srÚ anchor_meanÚ
anchor_tolrGÚ last_statusÚnowÚprober\Útsr!Úa_meanÚa_stdÚrel_tsÚslopeÚstableÚextras r,Úwait_for_stabilityr½³s3ô
I‰IK€EØ€KØ
Üi‰iØ ‰;˜Ò +˜e˜W G¨C°©I°c¨?¸ Ø— ‘ ˜# ™-ÓÜ ˆu‹:˜Š?Ü J‰JqŒMØ Ü
X‰X°Ö6¨1Ò
7ˆÜ
X‰X¨uÖ5¨!q˜“~Ò
Üq—v‘v“x“ˆÜq—u‘u“w“ˆØ‘e‘ˆØ6<¸R±jÀ1²n””b—jj ¨¨AÓ.¨qÑ2È#ˆà˜*ÑE¬3¨u«:¸ Ñ+DˆØ Ð " zÐ'=ØÒ V¨kÑ%9Ó!:¸jÑ!Hˆ Ü "U1°&¸°¸UÀ5ÈÀ+ðNؘt˜  J¨s°5©y¸¨o¸Qð@ô
Að"Ø$)Ø %™Kñ ð
ð Ñ ˜rÒ ˆEØÐ° Ñ);¸DÐ(AÐBÜ "U2°6¸#°,¸eÀEÈ#À;ðOؘt˜  J¨s°5©y¸¨o¸Q¸u¸gðGô
Hàˆ
ñI ùò7ùÚ5s  G$Â< G)có°|siSi}tD}|Dcgc] }||vsŒ||Œ}}|sŒtj|t¬«}t|j ««||d<t|j ««||d<t|j
««||d<t|j««||d<Œµt|«|d<|Scc}w)N)ÚdtypeÚ_meanÚ_stdÚ_minÚ_maxÚn) ÚCHANNELSrŠrbr„r…ÚminÚmaxrx)ÚsamplesrÚchr\ÚvalsÚarrs r,Ú window_statsrÌä٠؈ Ø
€CÜò-ˆØ2˜!¨"°ª'"“Ð2ˆÐØ Üh‰ht¤5ÔÜ! #§(¡(£*Ó-ˆˆrˆd%ˆÜ! #§'¡'£)Ó,ˆˆrˆd$ˆÜ! #§'¡'£)Ó,ˆˆrˆd$ˆÜ! #§'¡'£)Ó,ˆˆrˆd$ˆð7‹|€Cˆ €Jùò3s
” CžCcóÊi}|s|SdD]…}|d|vrŒ ||d}t|j|dd«d«}g}g}|D]>} || vsŒ|jt| |«|z
«|j| d|z
«Œ@|sŒ}t j
|«}
t j
|«} t j |
«} tt j| ««}
t|
|
«}t| |
«}t
|«|z }d}t
|«dz }t|
t|
««D]&}t
|
|«|ksŒt| ||z
«}n|||d <|||d
<|||d <|||d <t|
d
«||d<Œˆd|vrMd|vrIt
|d«}t
|d«}t||«dkDrt||«t||«z nd|d<|S)z=From pre baseline stats + post samples, derive the signature.)rrrrrrrr~g•Ö&è .>rMNg _peak_deltaÚ _peak_time_sÚ_snÚ _halflife_srÚ
_end_deltaÚstress_xx_peak_deltaÚstress_yy_peak_deltargð?Ústress_iso_ratio) rZrTrbrÚargmaxÚrangerx)Ú pre_statsÚ post_samplesÚ pre_anchor_tÚsigrÉÚbaserÚts_relÚdeltasr\Ú
deltas_arrÚts_arrÚabs_dÚidx_peakÚ
peak_deltaÚ peak_time_sÚsnÚ half_time_sr3ÚxxÚyys r,Úresponse_signaturerêõs5ð
€C٠؈
ð àˆTˆ<˜yÑ Ø˜B˜4˜u˜Ñ&ˆÜ9—== B 4 t ¨cÓ2°DÓØˆØˆØò >ˆAØQŠwØ
œe A b¡El¨TÑ
˜a  ™o° ÑØ Ü—XX˜
ܘ&Ó!ˆÜ"ˆÜ”r—yy Ó(ˆÜ˜J 1ˆ
ܘF -ˆ Ü
_˜
àˆ ÜZ“ &ˆÜ Ó ˆAÜ:˜a! # F¨1¡I° Ñ$;Ó< Ùð ð%/ˆˆrˆd ÑØ$/ˆˆrˆd Ñ Ø$&ˆˆrˆd#ˆJ‰Ø$/ˆˆrˆd ÑÜ$)¨*°R©.Ó$9ˆˆrˆd ÓðA :ðD Ñ$Ð)?À3Ñ)FÜ
Ð
-ˆÜ
Ð
ÜADÀRÈÃÈq¤3 r¨2£;´°R¸³Ò#<ÐVYˆÐ ÑØ €Jr1có¶dtttt|«dœ}t j«}|j t
j|««||dœS)inject_density)ÚcmdÚsigmar‡)Ú wall_sendÚpayload)ÚINJECT_XÚINJECT_YÚ
INJECT_SIGrbr#Ú send_stringrRÚdumps)Úpubr‡s r,Úfire_injectionrù&sIàÜÜܘ(“Oñ €Gô— ‘ “ €I؇OO”D—JJ˜"¨wÑ 7r1cóîtd|d|d«tj«}tj«|z
tkr4tjd«tj«|z
tkrŒ4|j |«}t |«}td|j
dd«d|j
d td
««d d |j
d
td
««d «t||«}|d} tj«| z
tkr4tjd«tj«| z
tkrŒ4|j | «}
t |
«} t||
| «} td| j
dd«d| j
dtd
««dd| j
dtd
««dd| j
d«d| j
dtd
««d
«t|t|«| tjdtj| ««|| | ttt g|dœ
}
|
Dcgc]7}it"Dcic]}||vsŒ||j
|«Œc}¥d|d| z
i¥Œ9c}}|
d<t$j'd «5}|j)t+j,|
«d!z«ddd«|
Scc}wcc}}w#1swY|
SxYw)"Nz INJECT ú strength=z+.4fr
z pre n=rÄrz asym mean=Úasymmetry_meanÚnanržÚ
asymmetry_stdrñz post n=z asym peak_delta=Úasymmetry_peak_deltaú+.3fz sn=Ú asymmetry_snz.2fz
halflife=Úasymmetry_halflife_szs stress_xy peak_delta=Ústress_xy_peak_deltaú+.6fr)
Úrun_idrr‡Ú wall_injectÚ
iso_injectrØÚ
post_statsÚ signatureÚinject_xy_sigmaÚbaseline_anchorÚrel_trMÚ
post_tracer!r")r-r#Ú PRE_RECORD_Sr¨r]rZrbÚ
POST_RECORD_SrêÚRUN_IDr$Ú localtimeróÚJSONLr'r(rR)rr‡r Ú pre_startÚ pre_samplesrØÚfireÚ inject_wallrÙrÚrecordr\Úkr+s r,Úrun_one_injectionr3äˆ)E7˜+ h¨t _Ð €IÜ
)‰)+˜ Ñ
!¤LÒ

ô )‰)+˜ Ñ
!¤LÓ
—))˜&€Kܘ)€I܈+i—m‘m C¨Ó+¨;°y·}±}ÐEUÔV[Ð\aÓVbÓ7cÐdgÐ6hðiØ}‰}˜_¬U°5«\Ó:¸3Ð AôBô ˜#˜xÓ (€DØ#€Kô )‰)‹+˜ Ñ
#¤mÒ

ô )‰)+˜ Ñ
#¤mÓ
—9‘9˜[Ó)€LܘlÓ+€Jä
˜ °kÓ
B€C܈+j—n‘n S¨Ó-ØŸ7™7Ð#9¼%À»,ÓÐNØg‰gn¤U¨5£\Ó2°3Ð
8Ø—G‘GÐ5 Ø #§¡Ð(>¼uÀU»|Ó LÈTÐ TôUôØÜ˜(“OØ—}}Ð%8¼$¿.¹.ÈÓ:UÓ ØÜ$¤h´