def reset_enqueued(job_type): q = u"update {} set started=null, finished=null".format(table_name(job_type)) run_sql(db, q)