import urllib.request,json,sqlite3
h=json.loads(urllib.request.urlopen('http://127.0.0.1:8644/health',timeout=30).read()); print('HEALTH',{k:h.get(k) for k in ['status','ready','neo4j_ready','provider_ready','provider_rate_limited','active_request_count']})
c=sqlite3.connect('file:/opt/struktur/graphiti/request-data/requests.db?mode=ro',uri=True); print('REQUESTS',c.execute('select count(*) from graphiti_requests').fetchone()[0],'ACTIVE',c.execute("select count(*) from graphiti_requests where status in ('started','processing')").fetchone()[0]); print('NEW',c.execute("select queue_id,request_id,status,http_status from graphiti_requests where request_id in ('req-5958d8b64c55eff9b032f42c','req-7d4863afa51c3c33c70ecfc5')").fetchall()); c.close()
q=sqlite3.connect('file:/opt/struktur/obsidian-graphiti-import/obsidian_graphiti_import.db?mode=ro',uri=True); print('COUNTS',q.execute('select status,count(*) from files group by status').fetchall()); print('ORIGINAL_FAILED_EXCLUDING_QUEUE11',q.execute("select count(*) from files where status='failed' and id != 11").fetchone()[0]); q.close(); print('BLOCK',json.load(open('/opt/struktur/obsidian-graphiti-import/import_run_block.json')))