fixes test listerner

Author: pcrespov

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

@@ -1471,6 +1471,7 @@ async def _trigger_connected_service_retrieve(
 
     # find the nodes that need to retrieve data
     for node_uuid, node in workbench.items():
+
         # check this node is dynamic
         if not _is_node_dynamic(node["key"]):
             continue
@@ -1482,18 +1483,20 @@ async def _trigger_connected_service_retrieve(
             if not isinstance(port_value, dict):
                 continue
 
-            input_node_uuid = port_value.get("nodeUuid")
+            # FIXME: hack to support both field and alias names because cannot guarantee which one is stored in workbench
+            input_node_uuid = port_value.get("nodeUuid", port_value.get("node_uuid"))
             if input_node_uuid != updated_node_uuid:
                 continue
+
             # so this node is linked to the updated one, now check if the port was changed?
             linked_input_port = port_value.get("output")
             if linked_input_port in changed_keys:
                 nodes_keys_to_update[node_uuid].append(port_key)
 
     # call /retrieve on the nodes
     update_tasks = [
-        dynamic_scheduler_service.retrieve_inputs(app, NodeID(node), keys)
-        for node, keys in nodes_keys_to_update.items()
+        dynamic_scheduler_service.retrieve_inputs(app, NodeID(node_id), keys)
+        for node_id, keys in nodes_keys_to_update.items()
     ]
     await logged_gather(*update_tasks, reraise=False)
 

services/web/server/tests/unit/with_dbs/04/notifications/test_notifications__db_comp_tasks_listening_task.py

@@ -232,8 +232,11 @@ async def mock_dynamic_service_rpc(
     """
     Mocks the dynamic service RPC calls to avoid actual service calls during tests.
     """
-    return mocker.patch(
-        "servicelib.rabbitmq.rpc_interfaces.dynamic_scheduler.services.retrieve_inputs",
+    import servicelib.rabbitmq.rpc_interfaces.dynamic_scheduler.services
+
+    return mocker.patch.object(
+        servicelib.rabbitmq.rpc_interfaces.dynamic_scheduler.services,
+        "retrieve_inputs",
         autospec=True,
     )