From 06fefe87ef3d98913386e897e5bcffa6df9941ca Mon Sep 17 00:00:00 2001 From: OhMaley Date: Tue, 1 Oct 2024 17:02:40 -0400 Subject: [PATCH] flake8 --- src/apps/analytics/tasks.py | 2 ++ src/apps/api/views/analytics.py | 2 +- 2 files changed, 3 insertions(+), 1 deletion(-) 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()