Skip to content

Commit

Permalink
tests/e2e_tests: sync pipeline tests to _get_node_event_data
Browse files Browse the repository at this point in the history
Signed-off-by: Ricardo Cañuelo <[email protected]>
  • Loading branch information
Ricardo Cañuelo committed Dec 15, 2023
1 parent e3cb1f7 commit 9fe1166
Showing 1 changed file with 4 additions and 2 deletions.
6 changes: 4 additions & 2 deletions tests/e2e_tests/test_pipeline.py
Original file line number Diff line number Diff line change
Expand Up @@ -61,7 +61,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', 'owner'}
keys = {'op', 'id', 'kind', 'name', 'path',
'group', 'state', 'result', 'owner', 'data'}
assert keys == event_data.keys()
assert event_data.get('op') == 'created'
assert event_data.get('id') == response.json()['id']
Expand All @@ -83,6 +84,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', 'owner'}
keys = {'op', 'id', 'kind', 'name', 'path',
'group', 'state', 'result', 'owner', 'data'}
assert keys == event_data.keys()
assert event_data.get('op') == 'updated'

0 comments on commit 9fe1166

Please sign in to comment.