diff --git a/src/apps/analytics/tasks.py b/src/apps/analytics/tasks.py index 833132789..246dbb13e 100644 --- a/src/apps/analytics/tasks.py +++ b/src/apps/analytics/tasks.py @@ -572,6 +572,7 @@ def reset_computed_storage_analytics(): ) ) + @app.task(queue="site-worker") def delete_orphan_files(): logger.info("Task delete_orphan_files started") @@ -620,6 +621,7 @@ def get_most_recent_storage_inconsistency_log_file(logger): return most_recent_log_file + def get_files_path_from_orphan_log_file(log_file_path, logger): files_path = [] diff --git a/src/apps/api/views/analytics.py b/src/apps/api/views/analytics.py index 5d482bcb9..0e87daefb 100644 --- a/src/apps/api/views/analytics.py +++ b/src/apps/api/views/analytics.py @@ -324,7 +324,7 @@ def delete_orphan_files(request): if not request.user.is_superuser: raise PermissionDenied(detail="Admin only") - + global delete_orphan_files_task delete_orphan_files_task = delete_orphan_files_async_task.delay()