import sqlite3, subprocess, urllib.request
for p in ['/opt/struktur/obsidian-graphiti-import/obsidian_graphiti_import.db','/opt/struktur/graphiti/request-data/requests.db']:
 print('DB',p); c=sqlite3.connect('file:'+p+'?mode=ro',uri=True); print(c.execute("select name from sqlite_master where type='table' order by name").fetchall())
 for t in ['graphiti_import_queue','graphiti_requests','episodes']:
  try: print(t,c.execute('pragma table_info('+t+')').fetchall())
  except Exception as e: print(t,e)
c=sqlite3.connect('file:/opt/struktur/obsidian-graphiti-import/obsidian_graphiti_import.db?mode=ro',uri=True)
print('RETRY_CANDIDATES')
for r in c.execute("select * from graphiti_import_queue where status='retry' order by queue_id"): print(r)
print('BLOCK',open('/opt/struktur/obsidian-graphiti-import/import_run_block.json').read())
print('PROCS',subprocess.run(['pgrep','-af','importer.py'],text=True,capture_output=True).stdout)
for u in ['http://127.0.0.1:8644/health','http://127.0.0.1:8655/v1/dashboard']:
 try: print(u,urllib.request.urlopen(u,timeout=20).read().decode()[:2000])
 except Exception as e: print(u,e)