···

       
3
       
3
       
 
       
import apsw

     

       
4
       
4
       
 
       


     

       
5
       
5
       
 
       
class FirehoseManager:

     

       
6
       
6
       
-
       
    def __init__(self, fname='firehose.db'):

     

       
6
       
6
       
+
       
    def __init__(self, fname='db/firehose.db'):

     

       
7
       
7
       
 
       
        self.db_cnx = apsw.Connection(fname)

     

       
8
       
8
       
 
       
        self.db_cnx.pragma('journal_mode', 'WAL')

     

       
9
       
9
       
 
       
        with self.db_cnx: