···

       
53
       
53
       
 
       
            post_uri = f'at://{repo}/{path}'

     

       
54
       
54
       
 
       
            ts = self.safe_timestamp(record['createdAt']).timestamp()

     

       
55
       
55
       
 
       


     

       
56
       
56
       
-
       
            with self.db_cnx:

     

       
57
       
57
       
-
       
                langs = record.get('langs') or ['']

     

       
58
       
58
       
-
       
                for lang in langs:

     

       
59
       
59
       
-
       
                    self.db_cnx.execute(

     

       
60
       
60
       
-
       
                        'insert into posts (uri, create_ts, lang) values (:uri, :ts, :lang)',

     

       
61
       
61
       
-
       
                        dict(uri=post_uri, ts=ts, lang=lang)

     

       
62
       
62
       
-
       
                    )

     

       
56
       
56
       
+
       
            langs = record.get('langs') or ['']

     

       
57
       
57
       
+
       
            for lang in langs:

     

       
58
       
58
       
+
       
                self.db_cnx.execute(

     

       
59
       
59
       
+
       
                    'insert into posts (uri, create_ts, lang) values (:uri, :ts, :lang)',

     

       
60
       
60
       
+
       
                    dict(uri=post_uri, ts=ts, lang=lang)

     

       
61
       
61
       
+
       
                )

     

       
63
       
62
       
 
       


     

       
64
       
63
       
 
       
    def run_tasks_minute(self):

     

       
65
       
64
       
 
       
        self.logger.debug('running minute tasks')