not sure why

sanderegg · sanderegg · commit c77fa8b36006 · 2025-08-25T11:29:17.000+02:00
diff --git a/services/web/server/src/simcore_service_webserver/notifications/_rabbitmq_exclusive_queue_consumers.py b/services/web/server/src/simcore_service_webserver/notifications/_rabbitmq_exclusive_queue_consumers.py
@@ -95,6 +95,7 @@ async def _computational_pipeline_status_message_parser(
         rabbit_message.user_id,
         include_state=True,
     )
+    _logger.info("We got an update of pipeline status %s", rabbit_message.run_result)
     if rabbit_message.run_result in RUNNING_STATE_COMPLETED_STATES:
         # the pipeline finished, the frontend needs to update all computational nodes
         computational_node_ids = (
@@ -104,7 +105,6 @@ async def _computational_pipeline_status_message_parser(
             )
             if _is_computational_node(n.key)
         )
-
         await limited_gather(
             *[
                 _projects_service.notify_project_node_update(

Original file line number	Diff line number	Diff line change
`@@ -95,6 +95,7 @@ async def _computational_pipeline_status_message_parser(`
`95`	`95`	`rabbit_message.user_id,`
`96`	`96`	`include_state=True,`
`97`	`97`	`)`
	`98`	`+ _logger.info("We got an update of pipeline status %s", rabbit_message.run_result)`
`98`	`99`	`if rabbit_message.run_result in RUNNING_STATE_COMPLETED_STATES:`
`99`	`100`	`# the pipeline finished, the frontend needs to update all computational nodes`
`100`	`101`	`computational_node_ids = (`
`@@ -104,7 +105,6 @@ async def _computational_pipeline_status_message_parser(`
`104`	`105`	`)`
`105`	`106`	`if _is_computational_node(n.key)`
`106`	`107`	`)`
`107`		`-`
`108`	`108`	`await limited_gather(`
`109`	`109`	`*[`
`110`	`110`	`_projects_service.notify_project_node_update(`