import sqlite3,json,datetime,subprocess
p='/opt/struktur/youtube-research/knowledge.db'
c=sqlite3.connect('file:'+p+'?mode=ro',uri=True); c.row_factory=sqlite3.Row
out={'checked_at_utc':datetime.datetime.now(datetime.timezone.utc).isoformat(),'queue_db':p}
out['statuses']=[dict(r) for r in c.execute('select graphiti_status,count(*) rows,count(distinct video_id) ids from graphiti_import_queue group by graphiti_status order by graphiti_status')]
out['source_statuses']=[dict(r) for r in c.execute('select source_type,graphiti_status,count(*) rows,count(distinct video_id) ids from graphiti_import_queue group by source_type,graphiti_status order by source_type,graphiti_status')]
out['recent']=[dict(r) for r in c.execute("select id,video_id,graphiti_status,attempt_count,graphiti_attempts,last_http_status,last_error_class,remote_outcome,next_attempt_at,graphiti_episode_id from graphiti_import_queue where updated_at >= '2026-08-28T22:28:00+00:00' order by updated_at desc limit 12")]
print(json.dumps(out,ensure_ascii=False))
print('AUDIT_BEGIN')
subprocess.run(['python3','/opt/struktur/graphiti/youtube_queue_neo4j_audit.py'],check=False)