diff --git a/search/search.py b/search/search.py index ae9560c..3b299f2 100644 --- a/search/search.py +++ b/search/search.py @@ -139,6 +139,8 @@ class ElasticSearchEngine(SearchEngine): except Exception as e: logger.error(str(e)) + logger.debug("Done deleting for " + str(website_id)) + def _delete(self, docs): bulk_string = self.create_bulk_delete_string(docs) result = self.es.bulk(body=bulk_string, index=self.index_name, doc_type="file", request_timeout=30) diff --git a/tasks.py b/tasks.py index dd94835..3b221fa 100644 --- a/tasks.py +++ b/tasks.py @@ -86,7 +86,6 @@ class TaskManager: self.db.log_result(task_result) - def queue_task(self, task: Task): self.db.put_task(task) print("Queued task and made it available to crawlers: " + str(task.website_id))