collector: persist skipped-only parser progress

collector: enforce outbox cap before replay

collector: fix daemon drain and backfill start

collector: preserve valid rows around ingest errors

collector: skip rejected rows after partial ingest

collector: add polling source runner