From 5a084cb8574252b4f10a6b8627fd95a80c8233ec Mon Sep 17 00:00:00 2001 From: Simon Date: Thu, 9 Aug 2018 17:12:43 -0400 Subject: [PATCH] Queue can be emptied more easily --- database.py | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/database.py b/database.py index 51edd67..948de9f 100644 --- a/database.py +++ b/database.py @@ -407,12 +407,12 @@ class Database: cursor = conn.cursor() 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() 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() return Task(task[1], task[2], task[3], task[4], task[5]) else: