mirror of
https://github.com/simon987/od-database.git
synced 2025-04-19 18:36:44 +00:00
revert task queuing pt. 2
This commit is contained in:
parent
4ce807c8a0
commit
801d056da8
2
app.py
2
app.py
@ -602,7 +602,7 @@ def api_complete_task():
|
|||||||
filename = "./tmp/" + str(task_result.website_id) + ".json"
|
filename = "./tmp/" + str(task_result.website_id) + ".json"
|
||||||
if not os.path.exists(filename):
|
if not os.path.exists(filename):
|
||||||
filename = None
|
filename = None
|
||||||
taskManager.complete_task(filename, task, task_result, name)
|
taskManager.complete_task(filename)
|
||||||
|
|
||||||
if filename and os.path.exists(filename):
|
if filename and os.path.exists(filename):
|
||||||
os.remove(filename)
|
os.remove(filename)
|
||||||
|
1
tasks.py
1
tasks.py
@ -87,7 +87,6 @@ class TaskManager:
|
|||||||
|
|
||||||
self.db.log_result(task_result)
|
self.db.log_result(task_result)
|
||||||
|
|
||||||
|
|
||||||
def queue_task(self, task: Task):
|
def queue_task(self, task: Task):
|
||||||
self.db.put_task(task)
|
self.db.put_task(task)
|
||||||
print("Queued task and made it available to crawlers: " + str(task.website_id))
|
print("Queued task and made it available to crawlers: " + str(task.website_id))
|
||||||
|
Loading…
x
Reference in New Issue
Block a user