44 lines
1.5 KiB
Python
44 lines
1.5 KiB
Python
import sqlite3
|
|
import os
|
|
|
|
def main():
|
|
# Die Datenbank liegt nach der Aufraeumaktion im data/ Ordner
|
|
db_path = os.path.join("data", "connector_queue.db")
|
|
|
|
if not os.path.exists(db_path):
|
|
print(f"ERROR: Database not found at {db_path}")
|
|
# Fallback fuer den Fall, dass das Skript im Root oder in einem Unterordner ausgefuehrt wird
|
|
db_path = "connector_queue.db"
|
|
if not os.path.exists(db_path):
|
|
print(f"ERROR: Fallback database also not found at {db_path}")
|
|
return
|
|
|
|
try:
|
|
conn = sqlite3.connect(db_path)
|
|
cursor = conn.cursor()
|
|
|
|
# Zaehlen, wie viele Jobs betroffen sind (FAILED und SKIPPED)
|
|
cursor.execute("SELECT COUNT(*) FROM jobs WHERE status IN ('FAILED', 'SKIPPED')")
|
|
count = cursor.fetchone()[0]
|
|
|
|
if count == 0:
|
|
print("No failed or skipped jobs found to requeue.")
|
|
return
|
|
|
|
print(f"Found {count} failed/skipped jobs in {db_path}. Re-queueing them for re-evaluation...")
|
|
|
|
# Alle FAILED- und SKIPPED-Jobs auf PENDING zuruecksetzen
|
|
cursor.execute("UPDATE jobs SET status = 'PENDING', error_msg = NULL WHERE status IN ('FAILED', 'SKIPPED')")
|
|
conn.commit()
|
|
|
|
print(f"✅ Success! {cursor.rowcount} jobs have been re-queued for processing.")
|
|
|
|
except sqlite3.Error as e:
|
|
print(f"Database error: {e}")
|
|
finally:
|
|
if 'conn' in locals() and conn:
|
|
conn.close()
|
|
|
|
if __name__ == "__main__":
|
|
main()
|