simon987/od-database
1
0
Fork 0
mirror of https://github.com/simon987/od-database.git synced 2025-04-19 18:36:44 +00:00
Code Issues Projects Releases Wiki Activity

Queue can be emptied more easily

Browse Source
This commit is contained in:
Simon 2018-08-09 17:12:43 -04:00
parent ffeed4192e
commit 5a084cb857
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
database.py
View File

@ -407,12 +407,12 @@ class Database:
cursor = conn.cursor() cursor = conn.cursor()
cursor.execute("SELECT id, website_id, url, priority, callback_type, callback_args FROM " cursor.execute("SELECT id, website_id, url, priority, callback_type, callback_args FROM "
"Queue WHERE website_id=? AND assigned_crawler=?", (website_id, name)) "Queue WHERE website_id=?", (website_id, name))
task = cursor.fetchone() task = cursor.fetchone()
if task: if task:
cursor.execute("DELETE FROM Queue WHERE website_id=? AND assigned_crawler=?", (website_id, name)) cursor.execute("DELETE FROM Queue WHERE website_id=?", (website_id, name))
conn.commit() conn.commit()
return Task(task[1], task[2], task[3], task[4], task[5]) return Task(task[1], task[2], task[3], task[4], task[5])
else: else: