Method flush_queue

huey/contrib/sql_huey.py:148–149

(self)

        return list(map(operator.itemgetter(0), query.tuples()))

    def flush_queue(self):
        self.Task.delete().where(self.Task.queue == self.name).execute()

    def add_to_schedule(self, data, timestamp):
        self.check_conn()