import sqlite3,json,datetime
p='/opt/struktur/youtube-research/knowledge.db'
c=sqlite3.connect('file:'+p+'?mode=ro',uri=True); c.row_factory=sqlite3.Row
rows=[dict(r) for r in c.execute("select id,video_id,graphiti_status,attempt_count,graphiti_attempts,last_attempt_at,updated_at,unknown_since,last_http_status,last_error_class,last_error_message,remote_outcome,graphiti_episode_id from graphiti_import_queue where graphiti_status='processing' order by id")]
print('QUEUE_PROCESSING'); print(json.dumps(rows,ensure_ascii=False))
q=[r['id'] for r in rows]
d=sqlite3.connect('file:/opt/struktur/graphiti/request-data/requests.db?mode=ro',uri=True); d.row_factory=sqlite3.Row
if q:
 marks=','.join('?'*len(q)); req=[dict(r) for r in d.execute('select request_id,queue_id,status,http_status,error_phase,terminal_reason,started_at,completed_at,llm_request_count,error_message from graphiti_requests where queue_id in ('+marks+') order by started_at desc',q)]
else: req=[]
print('REQUESTS'); print(json.dumps(req,ensure_ascii=False))