summaryrefslogtreecommitdiff
path: root/logs/mech.py
blob: 6762777049a6592dea7d2178220676196926b929 (plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
import sys, numpy as np, ot, torch
sys.path.insert(0,'/home/yurenh2/emm')
from scipy.optimize import linear_sum_assignment
from worldalign.synth_fast_gate import ClosedFormEnergy, fast_pair_descent
from worldalign.synth_triangle_gate import standardized
DEV=torch.device("cuda:1")
def standardise(m):
    mask=~np.eye(len(m),dtype=bool); v=m[mask]
    o=(m-v.mean())/v.std(); np.fill_diagonal(o,0.0); return o
def tlb(V,S):
    n=len(V); a=np.sort(V,1); b=np.sort(S,1)
    return (a*a).sum(1)[:,None]/n+(b*b).sum(1)[None,:]/n-2*(a@b.T)/n
st=torch.load("/home/yurenh2/emm/artifacts/synth_v1/omit_size.pt",map_location='cpu',weights_only=False)
V=standardise(st["visual_field"].double().numpy()); T=standardise(st["text_field"].double().numpy())
n=len(V); w=ot.unif(n)
for trial in range(3):
    rng=np.random.default_rng(trial); hid=rng.permutation(n); S=T[np.ix_(hid,hid)]
    Vg=standardized(torch.from_numpy(V).to(DEV)).double(); Sg=standardized(torch.from_numpy(S).to(DEV)).double()
    en=ClosedFormEnergy(Sg,Vg,1.0,0.0,64)
    Et=float(en.energy(torch.from_numpy(np.ascontiguousarray(np.argsort(hid))).to(DEV)[None])[0])
    acc=lambda c: float((hid[c]==np.arange(n)).mean())
    def refine(c,it=2000):
        f=fast_pair_descent(Sg,Vg,torch.from_numpy(np.ascontiguousarray(c)).to(DEV),it).cpu().numpy()
        return float(en.energy(torch.from_numpy(np.ascontiguousarray(f)).to(DEV)[None])[0]), acc(f)
    M=tlb(V,S); M=M/M.max()
    _,tlbcols=linear_sum_assignment(M)
    def vert(cols):
        P=np.zeros((n,n)); P[np.arange(n),cols]=1.0/n; return P
    starts={"tlb-vertex":tlbcols,
            "random-vertex":np.random.default_rng(50+trial).permutation(n),
            "grampa-vertex":None}
    from worldalign.spectral_match import grampa
    starts["grampa-vertex"]=grampa(V,S,1.0)
    print(f"--- trial {trial}  E_truth={Et:.6f}")
    for name,cols in starts.items():
        # (i) pure power step: LSAP on gradient V P S  (anchor-propagation, one round)
        P=vert(cols); grad=V@P@S
        _,c1=linear_sum_assignment(-grad)
        e1,a1=refine(c1)
        # (ii) 5 rounds of power step
        c=cols.copy()
        for _ in range(5):
            P=vert(c); _,c=linear_sum_assignment(-(V@P@S))
        e2,a2=refine(c)
        # (iii) warm FGW at alpha=0.1 then 0.2 from this vertex
        G=vert(cols)
        for a in (0.1,0.2,0.5):
            G=ot.gromov.fused_gromov_wasserstein(M,V,S,w,w,"square_loss",alpha=a,G0=G,max_iter=200,tol_rel=1e-9)
        _,c3=linear_sum_assignment(-G); e3,a3=refine(c3)
        print("  %-14s start=%.4f | 1 power step ->%.4f (E=%.4f) | 5 steps ->%.4f (E=%.4f) | warm FGW ->%.4f (E=%.4f)"
              %(name,acc(cols),a1,e1,a2,e2,a3,e3), flush=True)