"""Reuse the accepted scale harness, normalizing single and split child counters."""
from pathlib import Path
import sys
mode=sys.argv[1]
assert mode in ('pose','mixed')
source=Path('/tmp/codex/ltb1021/2026-09-26_provider-scale_r01/trial.py').read_text()
source=source.replace('19,20,21]','19,20]').replace('LEVELS=[1,2,4,8,16,17]','LEVELS=list(range(1,17))')
source=source.replace('>1000:', '>3600:')
source=source.replace("for p,v in r.get('provider_processes',{}).items()", "for p,v in (r.get('provider_processes') or {'pose':r}).items()")
source=source.replace("desired.update(fire=dict(enabled=True,scenario=dict(enabled=True)),tracking=dict(enabled=True))",
    "desired.update(fire=dict(enabled="+str(mode=='mixed')+",scenario=dict(enabled="+str(mode=='mixed')+")),tracking=dict(enabled=True),crowd=dict(enabled="+str(mode=='mixed')+"))")
source=source.replace("==['pose','fire','crowd']", "=="+repr(['pose'] if mode=='pose' else ['pose','fire','crowd']))
source=source.replace("len(r['providers'])==3", "len(r['providers'])=="+str(1 if mode=='pose' else 3))
source=source.replace("        artifacts={k:a.get(k) for k in ('rendering','active','activity','counts','peaks','error','storage_warning')})",
    "        artifacts={k:a.get(k) for k in ('rendering','active','activity','counts','peaks','error','storage_warning','ledger')}, training=training())")
source=source.replace("        stage['frames']=frame_probe(ORDER[:level])", "        stage['frames']=frame_probe(ORDER[:level])\n        stage['training']=training()\n        assert all(v['metadata_path']['execution_path']=='provider-linear-trial' and not v['metadata_path']['freshness_enabled'] for r in rows().values() for v in r['providers'].values())")
source=source.replace("            try:\n                changes={k:saved[c][k] for k in FIELDS}",
    "            try:\n                if c in launched and r[str(c)]['state'] != 'stopped':\n                    raise RuntimeError('RESTORE_DEFERRED_UNTIL_SERVICE_RESET')\n                changes={k:saved[c][k] for k in FIELDS}")
source=source.replace("print(json.dumps(dict(level=level,status='PASS'", "print(json.dumps(dict(mode="+repr(mode)+",level=level,status='PASS'")
exec(compile(source,__file__,'exec'))