Skip to content

reddit firehose: resume from stored posts; measure lag against the mirror - #282

Merged
ralyodio merged 1 commit into
mainfrom
reddit-firehose-resume
Nov 9, 2026
Merged

ralyodio merged 1 commit into
mainfrom
reddit-firehose-resume

Conversation

@ralyodio

@ralyodio ralyodio commented Nov 9, 2026

Copy link
Copy Markdown
Contributor

Follow-up to #281. Arctic Shift fell 37 min behind Reddit; a restart's clock-based cursor sat ahead of it and the lag skip would have jumped past un-ingested posts.

🤖 Generated with Claude Code

…rror

Arctic Shift's own ingestion fell 37 min behind Reddit (2026-11-09), and
a restart started the cursor at now-15 min, ahead of the mirror: every
page came back empty and posts between the mirror's head and the cursor
would never have been read.
- first pass resumes from the newest reddit post stored (feeds
  last_published_at) minus 2 min, not from the clock
- the 50-min skip jumps only to the mirror's newest post minus 5 min
  (one sort=desc limit=1 ask), so it never passes un-ingested posts

Co-Authored-By: Claude Opus 5.5 <noreply@anthropic.com>
@ralyodio
ralyodio merged commit 07175fd into main Nov 9, 2026
3 checks passed
@ralyodio
ralyodio deleted the reddit-firehose-resume branch November 9, 2026 21:01
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

None yet

Projects

None yet

Development

Successfully merging this pull request may close these issues.

1 participant