Improves logging and test debug visibility

Adds detailed debug logging to lock acquisition,
enhances pytest output with DEBUG logs for CI,
and clarifies mock subsystem setup for test reliability.
Facilitates easier diagnosis of concurrency and storage issues.

Author: matusdrobuliak66

packages/service-library/src/servicelib/redis/_decorators.py

@@ -53,6 +53,10 @@ def exclusive(
         lock_key -- a string as the name of the lock (good practice: app_name:lock_name)
         lock_value -- some additional data that can be retrieved by another client if None,
                     it will be automatically filled with the current time and the client name
+        blocking -- If ``blocking`` is False, always return immediately. If the lock
+                was acquired, return True, otherwise return False.
+        blocking_timeout -- specifies the maximum number of seconds to
+                wait trying to acquire the lock.
 
     Raises:
         - ValueError if used incorrectly
@@ -85,14 +89,21 @@ async def _wrapper(*args: P.args, **kwargs: P.kwargs) -> R:
                 lock_value = f"locked since {arrow.utcnow().format()} by {client.client_name} on {socket.gethostname()}"
 
             lock = client.create_lock(redis_lock_key, ttl=DEFAULT_LOCK_TTL)
+            _logger.debug(
+                "Acquiring lock '%s' with value '%s' for coroutine '%s'",
+                redis_lock_key,
+                lock_value,
+                coro.__name__,
+                stacklevel=3,
+            )
             if not await lock.acquire(
                 token=lock_value,
                 blocking=blocking,
                 blocking_timeout=(
                     blocking_timeout.total_seconds() if blocking_timeout else None
                 ),
             ):
-                raise CouldNotAcquireLockError(lock=lock)
+                raise CouldNotAcquireLockError(lock=lock)  # <-- HERE
 
             try:
                 async with asyncio.TaskGroup() as tg:

scripts/common-service.Makefile

@@ -175,6 +175,7 @@ _run-test-ci: _check_venv_active
 		--log-date-format="%Y-%m-%d %H:%M:%S" \
 		--log-format="%(asctime)s %(levelname)s %(message)s" \
 		--verbose \
+		--log-cli-level=DEBUG \
 		-m "not heavy_load" \
 		$(PYTEST_ADDITIONAL_PARAMETERS) \
 		$(TEST_TARGET)

services/web/server/src/simcore_service_webserver/projects/_projects_service.py

@@ -1060,7 +1060,7 @@ async def _remove_service_and_its_data_folders(
         )
 
     # remove the node's data if any
-    await storage_service.delete_data_folders_of_project_node(
+    await storage_service.delete_data_folders_of_project_node(  # <-- MD: this one
         app, f"{project_uuid}", node_uuid, user_id
     )
 

services/web/server/tests/unit/with_dbs/conftest.py

@@ -417,7 +417,12 @@ async def _mock_result() -> None:
         return_value=TypeAdapter(ByteSize).validate_python("1Gib"),
     )
 
-    return MockedStorageSubsystem(mock, mock1, mock2, mock3)
+    return MockedStorageSubsystem(
+        copy_data_folders_from_project=mock,
+        delete_project=mock1,
+        delete_node=mock2,
+        get_project_total_size_simcore_s3=mock3,
+    )
 
 
 @pytest.fixture