import sqlite3,time,json,datetime,subprocess
DB='/opt/struktur/youtube-research/knowledge.db'
for i in range(120):
 c=sqlite3.connect('file:'+DB+'?mode=ro',uri=True); c.row_factory=sqlite3.Row
 r=c.execute("select e.job_id,e.status,e.step,e.attempts,e.error_code,e.error_message,v.transcript_status,v.transcript_source,length(trim(coalesce(v.transcript,''))) n from e2e_jobs e join videos v on v.id=e.video_id where e.job_id=274").fetchone(); c.close()
 if r and r['status'] in ('complete','supadata_native_unavailable','video_unavailable','access_restricted','supadata_retry','supadata_quota_wait','discarded_after_processing_error','rejected_no_usable_transcript'):
  print(json.dumps(dict(r),ensure_ascii=False)); break
 time.sleep(2)
else: print(json.dumps({'timeout':True,'last':dict(r) if r else None}))