def migrate(rows): print("starting") for r in rows: print("row", r["id"]) db.execute("UPDATE users SET plan = '%s' WHERE id = %s" % (r["plan"], r["id"])) print("done", r["id"]) print("finished")