import sqlite3,json,urllib.request,subprocess
from pathlib import Path
Q='/opt/struktur/obsidian-graphiti-import/obsidian_graphiti_import.db'; R='/opt/struktur/graphiti/request-data/requests.db'; OUT='/opt/struktur/aa037'
q=sqlite3.connect('file:'+Q+'?mode=ro',uri=True); q.row_factory=sqlite3.Row
print('COUNTS', [tuple(x) for x in q.execute('select status,count(*) from files group by status')])
print('Q17',dict(q.execute('select id,relative_path,status,attempts,size,last_error,last_error_phase,graphiti_episode_uuid from files where id=17').fetchone()))
print('PILOT_RESULTS',[(x['id'],x['status'],x['graphiti_episode_uuid']) for x in q.execute('select id,status,graphiti_episode_uuid from files where id in (1,2,5,9,12,14,15,16,17) order by id')])
q.close(); r=sqlite3.connect('file:'+R+'?mode=ro',uri=True); print('REQUEST_TOTAL',r.execute('select count(*) from graphiti_requests').fetchone()[0]); print('ACTIVE_REQUESTS',r.execute("select count(*) from graphiti_requests where status in ('started','processing')").fetchone()[0]); print('AA037_REQUESTS',r.execute("select queue_id,request_id,status,http_status,episode_uuid from graphiti_requests where queue_id in ('1','2','5','9','12','14','15','16','17') order by rowid").fetchall()); r.close(); print('HEALTH',urllib.request.urlopen('http://127.0.0.1:8644/health').read().decode()); print('BLOCK',Path('/opt/struktur/obsidian-graphiti-import/import_run_block.json').read_text()); print('HASH',subprocess.check_output(['docker','exec','graphiti-service','sha256sum','/app/main.py','/app/llm_call_worker.py'],text=True)); print('CANDIDATES',len(json.load(open(OUT+'/candidates.json')))); print('RESULTS',len(json.load(open(OUT+'/results.json'))))