import sqlite3,json,urllib.request,hashlib
from pathlib import Path
Q='/opt/struktur/obsidian-graphiti-import/obsidian_graphiti_import.db'; R='/opt/struktur/graphiti/request-data/requests.db'
q=sqlite3.connect('file:'+Q+'?mode=ro',uri=True); print('COUNTS',q.execute('select status,count(*) from files group by status').fetchall()); print('PILOT',q.execute('select id,status,attempts,graphiti_episode_uuid from files where id in (31,13,69,182,166) order by id').fetchall()); q.close()
r=sqlite3.connect('file:'+R+'?mode=ro',uri=True); print('TOTAL',r.execute('select count(*) from graphiti_requests').fetchone()[0]); print('ACTIVE',r.execute("select count(*) from graphiti_requests where status in ('started','processing')").fetchone()[0]); print('LATEST',r.execute("select queue_id,request_id,status,http_status from graphiti_requests where queue_id in ('31','13','69','182','166') 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('PATCH_HASHES'); import subprocess; print(subprocess.check_output(['docker','exec','graphiti-service','sha256sum','/app/main.py','/app/llm_call_worker.py'],text=True))