periodic task and products

Author: pcrespov

services/web/server/src/simcore_service_webserver/garbage_collector/_tasks_trash.py

@@ -8,6 +8,7 @@
 from collections.abc import AsyncIterator, Callable
 
 from aiohttp import web
+from servicelib.logging_utils import log_context
 from tenacity import retry
 from tenacity.before_sleep import before_sleep_log
 from tenacity.wait import wait_exponential
@@ -28,11 +29,8 @@
     before_sleep=before_sleep_log(_logger, logging.WARNING),
 )
 async def _run_task(app: web.Application):
-    if deleted := await trash_service.delete_expired_trash_as_admin(app):
-        for name in deleted:
-            _logger.info("Trash item %s expired and was deleted", f"{name}")
-    else:
-        _logger.info("No trash items expired")
+    with log_context(_logger, logging.INFO, "Deleting expired trashed items"):
+        await trash_service.delete_expired_trash_as_admin(app)
 
 
 async def _run_periodically(app: web.Application, wait_interval_s: float):

services/web/server/src/simcore_service_webserver/trash/_service.py

@@ -8,6 +8,7 @@
 from models_library.users import UserID
 from servicelib.logging_errors import create_troubleshotting_log_kwargs
 from servicelib.logging_utils import log_context
+from simcore_service_webserver.products import _api as products_service
 
 from ..folders import folders_trash_service
 from ..projects import projects_trash_service
@@ -108,32 +109,38 @@ async def empty_trash_safe(
 
 async def delete_expired_trash_as_admin(app: web.Application) -> list[str]:
     settings = get_plugin_settings(app)
-
-    # app-wide
     retention = timedelta(days=settings.TRASH_RETENTION_DAYS)
     delete_until = arrow.now().datetime - retention
 
-    with log_context(
-        _logger,
-        logging.DEBUG,
-        "CODE PLACEHOLDER: **ALL** items marked as trashed during %s days are deleted (those marked before %s)",
-        retention,
-        delete_until,
-    ):
-        try:
-            await folders_trash_service.batch_delete_trashed_folders_as_admin(
-                app, trashed_before=delete_until, product_name="TODO", fail_fast=False
-            )
-        except Exception as exc:  # pylint: disable=broad-exception-caught
-            _logger.warning(
-                **create_troubleshotting_log_kwargs(
-                    "Error deleting a trashed folders (and content) that were expired.",
-                    error=exc,
-                    error_context={
-                        "delete_until": delete_until,
-                        "retention": retention,
-                    },
+    for product in products_service.list_products(app):
+        with log_context(
+            _logger,
+            logging.DEBUG,
+            "Items marked as trashed before %s in %s [retention=%s]",
+            retention,
+            product.display_name,
+            delete_until,
+        ):
+            try:
+
+                await folders_trash_service.batch_delete_trashed_folders_as_admin(
+                    app,
+                    trashed_before=delete_until,
+                    product_name=product.name,
+                    fail_fast=False,
+                )
+
+            except Exception as exc:  # pylint: disable=broad-exception-caught
+                _logger.warning(
+                    **create_troubleshotting_log_kwargs(
+                        "Error batch deleting expired trashed folders as admin.",
+                        error=exc,
+                        error_context={
+                            "delete_until": delete_until,
+                            "retention": retention,
+                            "product_name": product.name,
+                        },
+                    )
                 )
-            )
 
     return []