| 122 | return self.cursor.fetchall() |
| 123 | |
| 124 | def init(self): |
| 125 | self.execute("CREATE TABLE IF NOT EXISTS logs(id INTEGER PRIMARY KEY AUTOINCREMENT, taskid INTEGER, time TEXT, level TEXT, message TEXT)") |
| 126 | self.execute("CREATE TABLE IF NOT EXISTS data(id INTEGER PRIMARY KEY AUTOINCREMENT, taskid INTEGER, status INTEGER, content_type INTEGER, value TEXT)") |
| 127 | self.execute("CREATE TABLE IF NOT EXISTS errors(id INTEGER PRIMARY KEY AUTOINCREMENT, taskid INTEGER, error TEXT)") |
| 128 | |
| 129 | class Task(object): |
| 130 | def __init__(self, taskid, remote_addr): |