#!/bin/bash
# AA-043 single writer batch: process all eligible queued aa043 rows.
DB=/opt/struktur/youtube-research/knowledge.db
WRITER=/opt/struktur/obsidian-graphiti-reconciler-staging/aa043_single_writer.py
QIDS=$(sqlite3 "$DB" "select id from graphiti_import_queue where reconciliation_record_id like 'aa043:%' and graphiti_status in ('queued','retry_wait','lease_expired') order by id")
for qid in $QIDS; do
  echo "== processing queue $qid =="
  cd /opt/obsidian-vault
  /usr/bin/python3 "$WRITER" --queue-id "$qid" || echo "queue $qid failed, continuing"
done
echo "batch done"