···

       
61
       
61
       
 
       
    async for commit in firehose_events(firehose_manager):

     

       
62
       
62
       
 
       
        feed_manager.process_commit(commit)

     

       
63
       
63
       
 
       
        event_count += 1

     

       
64
       
64
       
-
       
        if event_count % 2000 == 0:

     

       
64
       
64
       
+
       
        if event_count % 2500 == 0:

     

       
65
       
65
       
 
       
            feed_manager.commit_changes()

     

       
66
       
66
       
 
       
            firehose_manager.set_sequence_number(commit['seq'])

     

       
67
       
67