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

Configure Feed

Select the types of activity you want to include in your feed.

firehose-checkpoint.py: flush more often

Eric Davis 6b4dc0ef a670aa5d

+2 -1
+2 -1
firehose-checkpoint.py
··· 34 34 35 35 redis_cnx.set('bsky-tools:firehose:subscribe-repos:seq', payload_seq) 36 36 sys.stdout.write(f'seq: {payload_seq}, lag: {payload_lag.total_seconds()}\n') 37 - sys.stdout.flush() 37 + 38 + sys.stdout.flush() 38 39 39 40 if __name__ == '__main__': 40 41 asyncio.run(main())