···

       
44
       
44
       
 
       
            return

     

       
45
       
45
       
 
       


     

       
46
       
46
       
 
       
        if inner_record.get('uri') == TARGET_QUOTE_URI:

     

       
47
       
47
       
+
       
            self.transaction_begin(self.db_cnx)

     

       
47
       
48
       
 
       
            self.logger.debug('found quote post of target, adding to feed')

     

       
48
       
49
       
 
       
            uri = 'at://{repo}/app.bsky.feed.post/{rkey}'.format(

     

       
49
       
50
       
 
       
                repo = commit['did'],

     
···

       
57
       
58
       
 
       


     

       
58
       
59
       
 
       
    def commit_changes(self):

     

       
59
       
60
       
 
       
        self.logger.debug('committing changes')

     

       
61
       
61
       
+
       
        self.transaction_commit(self.db_cnx)

     

       
60
       
62
       
 
       
        self.wal_checkpoint(self.db_cnx, 'RESTART')

     

       
61
       
63
       
 
       


     

       
62
       
64
       
 
       
    def serve_feed(self, limit, offset, langs):