···

       
12
       
12
       
 
       
        self.logger = logging.getLogger('feeds.firehose')

     

       
13
       
13
       
 
       


     

       
14
       
14
       
 
       
    def get_sequence_number(self):

     

       
15
       
15
       
-
       
        cur = self.db_cnx.execute("select * from firehose where key = 'seq'")

     

       
16
       
16
       
-
       
        row = cur.fetchone()

     

       
15
       
15
       
+
       
        row = self.db_cnx.execute("select * from firehose where key = 'seq'").fetchone()

     

       
17
       
16
       
 
       
        if row is None:

     

       
18
       
17
       
 
       
            return None

     

       
19
       
18
       
 
       
        (key, value) = row