fix test and structure of db payload

ITISFoundation · Apr 25, 2023 · daed72c · daed72c
1 parent 6e5da21
commit daed72c
Show file tree

Hide file tree

Showing 2 changed files with 7 additions and 2 deletions.
diff --git a/...s/web/server/src/simcore_service_webserver/notifications/_db_comp_tasks_listening_task.py b/...s/web/server/src/simcore_service_webserver/notifications/_db_comp_tasks_listening_task.py
@@ -55,8 +55,10 @@ async def _update_project_state(
 
 @dataclass(frozen=True)
 class _CompTaskNotificationPayload:
+    action: str
     data: dict
     changes: dict
+    table: str
 
 
 async def _handle_db_notification(

diff --git a/...ices/web/server/tests/unit/with_dbs/01/notifications/test_db_comp_tasks_listening_task.py b/...ices/web/server/tests/unit/with_dbs/01/notifications/test_db_comp_tasks_listening_task.py
@@ -143,7 +143,10 @@ async def test_listen_comp_tasks_task(
     some_project = project(logged_user)
     pipeline(project_id=f"{some_project.uuid}")
     task = comp_task(
-        project_id=f"{some_project.uuid}", outputs=json.dumps({}), node_class=task_class
+        project_id=f"{some_project.uuid}",
+        node_id=faker.uuid4(),
+        outputs=json.dumps({}),
+        node_class=task_class,
     )
     async with db_engine.acquire() as conn:
         # let's update some values
@@ -153,7 +156,7 @@ async def test_listen_comp_tasks_task(
             .where(comp_tasks.c.task_id == task["task_id"])
         )
 
-        # tests whether listener gets hooked calls executed
+        # tests whether listener gets executed
         for call_name, mocked_call in mock_project_subsystem.items():
             if call_name in expected_calls:
                 async for attempt in AsyncRetrying(