Skip to content
Snippets Groups Projects

Send process_id when updating worker activity

Merged Valentin Rigal requested to merge process-id into master
1 file
+ 8
1
Compare changes
  • Side-by-side
  • Inline
# -*- coding: utf-8 -*-
# . -*- coding: utf-8 -*-
import json
import sys
@@ -108,6 +108,7 @@ def test_update_call(responses, mock_elements_worker, mock_process_api):
status=200,
json={
"element_id": "1234-deadbeef",
"process_id": "aaaaaaaa-bbbb-cccc-dddd-eeeeeeeeffff",
"state": "processed",
},
)
@@ -117,6 +118,7 @@ def test_update_call(responses, mock_elements_worker, mock_process_api):
# Check the response received by worker
assert out == {
"element_id": "1234-deadbeef",
"process_id": "aaaaaaaa-bbbb-cccc-dddd-eeeeeeeeffff",
"state": "processed",
}
@@ -133,6 +135,7 @@ def test_update_call(responses, mock_elements_worker, mock_process_api):
# Check the request sent by worker
assert json.loads(responses.calls[-1].request.body) == {
"element_id": "1234-deadbeef",
"process_id": "aaaaaaaa-bbbb-cccc-dddd-eeeeeeeeffff",
"state": "processed",
}
@@ -184,6 +187,7 @@ def test_run(
status=200,
json={
"element_id": "1234-deadbeef",
"process_id": "aaaaaaaa-bbbb-cccc-dddd-eeeeeeeeffff",
"state": "started",
},
)
@@ -193,6 +197,7 @@ def test_run(
status=200,
json={
"element_id": "1234-deadbeef",
"process_id": "aaaaaaaa-bbbb-cccc-dddd-eeeeeeeeffff",
"state": final_state,
},
)
@@ -232,10 +237,12 @@ def test_run(
# Check the requests sent by worker
assert json.loads(responses.calls[-2].request.body) == {
"element_id": "1234-deadbeef",
"process_id": "aaaaaaaa-bbbb-cccc-dddd-eeeeeeeeffff",
"state": "started",
}
assert json.loads(responses.calls[-1].request.body) == {
"element_id": "1234-deadbeef",
"process_id": "aaaaaaaa-bbbb-cccc-dddd-eeeeeeeeffff",
"state": final_state,
}
Loading