File size: 1,395 Bytes
98bde72 | 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 | """Run a frozen list of episodes with explicit per-episode input files.
The manifest is JSON list. Each row supplies spec, registry, controller, trace.
This runner records failures and never invents task inputs or fills results.
"""
import argparse,json,subprocess,sys,hashlib
from pathlib import Path
def main():
p=argparse.ArgumentParser();p.add_argument('manifest');p.add_argument('--output',required=True);p.add_argument('--dry-run',action='store_true');a=p.parse_args()
rows=json.loads(Path(a.manifest).read_text());report=[]
for r in rows:
hashes={}
for key in ['spec','registry','controller']:
path=Path(r[key]);hashes[key]=hashlib.sha256(path.read_bytes()).hexdigest()
command=[sys.executable,'-m','peppa.cli','run','--spec',r['spec'],'--registry',r['registry'],'--controller',r['controller'],'--trace',r['trace']]
status={'episode':r.get('episode',r['trace']),'hashes':hashes,'command':command}
if a.dry_run:status['status']='validated paths'
else:
result=subprocess.run(command,text=True,capture_output=True,check=False)
status.update(returncode=result.returncode,stdout=result.stdout,stderr=result.stderr)
report.append(status)
Path(a.output).parent.mkdir(parents=True,exist_ok=True);Path(a.output).write_text(json.dumps(report,indent=2))
if __name__=='__main__':main()
|