from ops import *
exec(compile(Path('/tmp/codex/ltb1021/2026-09-26_provider-scale_r01/prepare.py').read_text(), __file__, 'exec'))
shutil.copyfile('/workspace/contextra-runtime-config/metadata-active/compose.yaml', PRIVATE/'metadata-compose.before.yaml')
save('training-before.json', training())
c = inspect('contextra-analytics-1')
env = dict(v.split('=', 1) for v in c['Config']['Env'])
print(json.dumps(dict(pid=c['State']['Pid'], settings={k:v for k,v in env.items() if k.startswith(('CONTEXTRA_PROVIDER_', 'CONTEXTRA_COMPLETED_QUEUE_', 'CONTEXTRA_PIPELINE_DIAGNOSTICS', 'CONTEXTRA_EVENT_COOLDOWN', 'CONTEXTRA_TEST_NO_CAPTURE'))},
                     channels=[dict(state=r['state'], child_pid=r.get('child_pid')) for r in rows if r['state'] != 'stopped'])))