edavis.dev / bsky-tools
this repo has no description
fork atom

feedgen: commit every 2k events

Eric Davis c810f856 d0eaa6cc

+1 -1
+1 -1
feedgen.py
··· 60 60 async for commit in firehose_events(firehose_manager): 61 61 feed_manager.process_commit(commit) 62 62 event_count += 1 63 - if event_count % 500 == 0: 63 + if event_count % 2000 == 0: 64 64 feed_manager.commit_changes() 65 65 firehose_manager.set_sequence_number(commit['seq']) 66 66