Skip to content
Snippets Groups Projects
Commit 96b2301d authored by Valentin Rigal's avatar Valentin Rigal
Browse files

Update tests

parent 1dec7afb
No related branches found
No related tags found
1 merge request!108Send process_id when updating worker activity
Pipeline #78548 passed
# -*- coding: utf-8 -*- # . -*- coding: utf-8 -*-
import json import json
import sys import sys
...@@ -108,6 +108,7 @@ def test_update_call(responses, mock_elements_worker, mock_process_api): ...@@ -108,6 +108,7 @@ def test_update_call(responses, mock_elements_worker, mock_process_api):
status=200, status=200,
json={ json={
"element_id": "1234-deadbeef", "element_id": "1234-deadbeef",
"process_id": "aaaaaaaa-bbbb-cccc-dddd-eeeeeeeeffff",
"state": "processed", "state": "processed",
}, },
) )
...@@ -117,6 +118,7 @@ def test_update_call(responses, mock_elements_worker, mock_process_api): ...@@ -117,6 +118,7 @@ def test_update_call(responses, mock_elements_worker, mock_process_api):
# Check the response received by worker # Check the response received by worker
assert out == { assert out == {
"element_id": "1234-deadbeef", "element_id": "1234-deadbeef",
"process_id": "aaaaaaaa-bbbb-cccc-dddd-eeeeeeeeffff",
"state": "processed", "state": "processed",
} }
...@@ -133,6 +135,7 @@ def test_update_call(responses, mock_elements_worker, mock_process_api): ...@@ -133,6 +135,7 @@ def test_update_call(responses, mock_elements_worker, mock_process_api):
# Check the request sent by worker # Check the request sent by worker
assert json.loads(responses.calls[-1].request.body) == { assert json.loads(responses.calls[-1].request.body) == {
"element_id": "1234-deadbeef", "element_id": "1234-deadbeef",
"process_id": "aaaaaaaa-bbbb-cccc-dddd-eeeeeeeeffff",
"state": "processed", "state": "processed",
} }
...@@ -184,6 +187,7 @@ def test_run( ...@@ -184,6 +187,7 @@ def test_run(
status=200, status=200,
json={ json={
"element_id": "1234-deadbeef", "element_id": "1234-deadbeef",
"process_id": "aaaaaaaa-bbbb-cccc-dddd-eeeeeeeeffff",
"state": "started", "state": "started",
}, },
) )
...@@ -193,6 +197,7 @@ def test_run( ...@@ -193,6 +197,7 @@ def test_run(
status=200, status=200,
json={ json={
"element_id": "1234-deadbeef", "element_id": "1234-deadbeef",
"process_id": "aaaaaaaa-bbbb-cccc-dddd-eeeeeeeeffff",
"state": final_state, "state": final_state,
}, },
) )
...@@ -232,10 +237,12 @@ def test_run( ...@@ -232,10 +237,12 @@ def test_run(
# Check the requests sent by worker # Check the requests sent by worker
assert json.loads(responses.calls[-2].request.body) == { assert json.loads(responses.calls[-2].request.body) == {
"element_id": "1234-deadbeef", "element_id": "1234-deadbeef",
"process_id": "aaaaaaaa-bbbb-cccc-dddd-eeeeeeeeffff",
"state": "started", "state": "started",
} }
assert json.loads(responses.calls[-1].request.body) == { assert json.loads(responses.calls[-1].request.body) == {
"element_id": "1234-deadbeef", "element_id": "1234-deadbeef",
"process_id": "aaaaaaaa-bbbb-cccc-dddd-eeeeeeeeffff",
"state": final_state, "state": final_state,
} }
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment