def _sqlite_load(self):
    conn = self.session.connection()
    cursor = conn.connection.cursor()
    with open(self.options['sql_path'], 'r') as f:
        try:
            cursor.executescript(f.read())
        finally:
            cursor.close()
def _sqlite_load(self):
    conn = self.session.connection()
    cursor = conn.connection.cursor()
    with open(self.options['sql_path'], 'r') as f:
        try:
            cursor.executescript(f.read())
        finally:
            cursor.close()