From d9e7a513251d4306c3728720e032913c2860e8b1 Mon Sep 17 00:00:00 2001 From: dchhabda Date: Wed, 2 Oct 2024 13:44:34 -0400 Subject: [PATCH] record time for task deletion --- pybossa/repositories/task_repository.py | 23 +++++++++++++++++++++++ 1 file changed, 23 insertions(+) diff --git a/pybossa/repositories/task_repository.py b/pybossa/repositories/task_repository.py index 69ec10254..281062f3f 100644 --- a/pybossa/repositories/task_repository.py +++ b/pybossa/repositories/task_repository.py @@ -35,6 +35,7 @@ from sqlalchemy import or_ from sqlalchemy.sql import case as sqlalchemy_case from pybossa.task_creator_helper import get_task_expiration +import time class TaskRepository(Repository): @@ -201,11 +202,33 @@ def update(self, element): raise DBIntegrityError(e) def delete(self, element): + current_app.logger.info("delete request for task %d, project %d", element.id, element.project_id) + start_time = time.time() + + tstart = time.time() self._delete(element) + tend = time.time() + current_app.logger.info("Time for self._delete %f seconds (task %d, project %d)", tend - tstart, element.id, element.project_id) + project = element.project + tstart = time.time() self.db.session.commit() + tend = time.time() + current_app.logger.info("Time for self.db.session.commit %f seconds (task %d, project %d)", tend - tstart, element.id, element.project_id) + + tstart = time.time() cached_projects.clean_project(element.project_id) + tend = time.time() + current_app.logger.info("Time for cached_projects.clean_project %f seconds (task %d, project %d)", tend - tstart, element.id, element.project_id) + + tstart = time.time() self._delete_zip_files_from_store(project) + tend = time.time() + current_app.logger.info("Time for self._delete_zip_files_from_store %f seconds (task %d, project %d)", tend - tstart, element.id, element.project_id) + + end_time = time.time() + time_diff = end_time - start_time + current_app.logger.info("Total deletion time for task %d, project %d was %f seconds", element.id, element.project_id, time_diff) def delete_task_by_id(self, project_id, task_id): from pybossa.jobs import check_and_send_task_notifications