Skip to content

Commit be8dab7

Browse files
Fix unit test
1 parent 974645d commit be8dab7

File tree

2 files changed

+4
-1
lines changed

2 files changed

+4
-1
lines changed

contrib/runners/orquesta_runner/tests/unit/test_basic.py

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -48,6 +48,7 @@
4848
from st2common.transport import liveaction as lv_ac_xport
4949
from st2common.transport import workflow as wf_ex_xport
5050
from st2common.transport import publishers
51+
from st2common.util import system_info
5152
from st2tests.mocks import liveaction as mock_lv_ac_xport
5253
from st2tests.mocks import workflow as mock_wf_ex_xport
5354

@@ -165,6 +166,7 @@ def test_run_workflow(self):
165166
expected_lv_ac_ctx = {
166167
"workflow_execution": str(wf_ex_db.id),
167168
"pack": "orquesta_tests",
169+
"engine_info": system_info.get_process_info(),
168170
}
169171

170172
self.assertDictEqual(lv_ac_db.context, expected_lv_ac_ctx)

st2actions/st2actions/workflows/workflows.py

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -30,6 +30,7 @@
3030
from st2common.transport import queues
3131
from st2common.transport import utils as txpt_utils
3232

33+
3334
LOG = logging.getLogger(__name__)
3435

3536

@@ -126,8 +127,8 @@ def fail_workflow_execution(self, message, exception):
126127

127128
@wf_svc.add_system_info_to_action_context
128129
def handle_workflow_execution(self, wf_ex_db):
129-
wf_svc.update_progress(wf_ex_db, "Processing request for workflow execution.")
130130
# Request the next set of tasks to execute.
131+
wf_svc.update_progress(wf_ex_db, "Processing request for workflow execution.")
131132
wf_svc.request_next_tasks(wf_ex_db)
132133

133134
@wf_svc.add_system_info_to_action_context

0 commit comments

Comments
 (0)