gistfile1.py

class Query(Task):
    @staticmethod
    def executor(qname):
        cx = sqlite3.connect(get_dbfile())
        cx.row_factory = sqlite3.Row
        queue = get_queue(qname)
        while True:
            task = queue.get()
            for query, args in task.queries:
                result = cx.execute(query, args)
            cx.commit()
            if result:
                task.put(result)
                result = None
    def __init__(self):
        self.queries = []
        Task.__init__(self, 'Query')
    def add(self, query, args):
        self.queries.append((query, args))
        return self