use user_message

Author: sanderegg

services/director-v2/src/simcore_service_director_v2/modules/comp_scheduler/_scheduler_base.py

@@ -21,6 +21,7 @@
 
 import arrow
 import networkx as nx
+from common_library.user_messages import user_message
 from models_library.projects import ProjectID
 from models_library.projects_nodes_io import NodeID, NodeIDStr
 from models_library.projects_state import RunningState
@@ -247,7 +248,9 @@ async def _set_run_result(
                 self.rabbitmq_client,
                 user_id=user_id,
                 project_id=project_id,
-                log=f"Pipeline run {run_result.value} for iteration {iteration} is done with {run_result.value} state",
+                log=user_message(
+                    f"Pipeline run {run_result.value} for iteration {iteration} is done with {run_result.value} state"
+                ),
                 log_level=logging.INFO,
             )
         await publish_pipeline_scheduling_state(
@@ -861,7 +864,9 @@ async def _schedule_tasks_to_start(
                 self.rabbitmq_client,
                 user_id,
                 project_id,
-                log="Unexpected error while scheduling computational tasks! TIP: contact osparc support if this does not resolve automatically.",
+                log=user_message(
+                    "Unexpected error while scheduling computational tasks! TIP: contact osparc support if this does not resolve automatically."
+                ),
                 log_level=logging.ERROR,
             )
             await CompTasksRepository.instance(
@@ -997,7 +1002,9 @@ async def _timeout_if_waiting_for_cluster_too_long(
                 )
                 for task in tasks_waiting_for_cluster:
                     task.state = RunningState.FAILED
-                msg = "Timed-out waiting for computational cluster! Please try again and/or contact Osparc support."
+                msg = user_message(
+                    "Timed-out waiting for computational cluster! Please try again and/or contact Osparc support."
+                )
                 _logger.error(msg)
                 await publish_project_log(
                     self.rabbitmq_client,