From b031e96ef2c5a02fe6487dba9481f6b1372ff1b5 Mon Sep 17 00:00:00 2001 From: Brandon Thomas Date: Sat, 25 Jun 2022 11:32:23 -0400 Subject: [PATCH] Python needed to commit! Ugh! --- tools/delete_tts_inference_jobs.py | 18 ++++++++++++++++-- 1 file changed, 16 insertions(+), 2 deletions(-) diff --git a/tools/delete_tts_inference_jobs.py b/tools/delete_tts_inference_jobs.py index 980d070bdb..849cda4d01 100755 --- a/tools/delete_tts_inference_jobs.py +++ b/tools/delete_tts_inference_jobs.py @@ -50,14 +50,24 @@ LIMIT = 100000 total_count = 75082057 +def get_first_record(cursor): + query = f"select * from tts_inference_jobs order by id limit 1" + cursor.execute(query) + result = cursor.fetchall() + print(result) + return result + total_deleted = 0 keep_deleting = True while keep_deleting: - query = f"DELETE FROM tts_inference_jobs WHERE id < {SAFE_ID} ORDER BY ID desc LIMIT {LIMIT}" + #query = f"DELETE FROM tts_inference_jobs WHERE id < {SAFE_ID} ORDER BY ID ASC LIMIT {LIMIT}" + query = f"DELETE FROM tts_inference_jobs ORDER BY ID asc LIMIT {LIMIT}" + print(query) cursor.execute(query) + connection.commit() #result = cursor.fetchall() count = cursor.rowcount @@ -70,5 +80,9 @@ while keep_deleting: if count < LIMIT - 1: keep_deleting = False - #time.sleep(0.2) + time.sleep(2) + + record = get_first_record(cursor) + + time.sleep(2)