tests/e2e_tests: update assertion for pubsub event data

`Node.owner` field has been added to pubsub event data for `node` channel. Update assert statement for verifying pubsub event data in `test_node_pipeline` accordingly. Signed-off-by: Jeny Sadadia <[email protected]>
JenySadadia · Sep 5, 2023 · 7b137f3 · 7b137f3
1 parent 83c6822
commit 7b137f3
Showing 1 changed file with 4 additions and 2 deletions.
diff --git a/tests/e2e_tests/test_pipeline.py b/tests/e2e_tests/test_pipeline.py
@@ -59,7 +59,8 @@ async def test_node_pipeline(test_async_client):
     await task_listen
     event_data = from_json(task_listen.result().json().get('data')).data
     assert event_data != 'BEEP'
-    keys = {'op', 'id', 'name', 'path', 'group', 'state', 'result', 'revision'}
+    keys = {'op', 'id', 'name', 'path', 'group', 'state', 'result', 'revision',
+            'owner'}
     assert keys == event_data.keys()
     assert event_data.get('op') == 'created'
     assert event_data.get('id') == response.json()['id']
@@ -81,6 +82,7 @@ async def test_node_pipeline(test_async_client):
     await task_listen
     event_data = from_json(task_listen.result().json().get('data')).data
     assert event_data != 'BEEP'
-    keys = {'op', 'id', 'name', 'path', 'group', 'state', 'result', 'revision'}
+    keys = {'op', 'id', 'name', 'path', 'group', 'state', 'result', 'revision',
+            'owner'}
     assert keys == event_data.keys()
     assert event_data.get('op') == 'updated'