status-im
/
spiff-arena
mirror of https://github.com/status-im/spiff-arena.git
2
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

POC for saving some data about each step

This commit is contained in:
Jon Herron 2023-02-06 15:59:26 -05:00
parent c00338e951
commit a40b023593
1 changed files with 14 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

17
spiffworkflow-backend/src/spiffworkflow_backend/services/process_instance_processor.py
View File

@ -30,6 +30,7 @@ from SpiffWorkflow.bpmn.PythonScriptEngine import PythonScriptEngine # type: ig
from SpiffWorkflow.bpmn.PythonScriptEngineEnvironment import BasePythonScriptEngineEnvironment # type: ignore from SpiffWorkflow.bpmn.PythonScriptEngineEnvironment import BasePythonScriptEngineEnvironment # type: ignore
from SpiffWorkflow.bpmn.PythonScriptEngineEnvironment import Box from SpiffWorkflow.bpmn.PythonScriptEngineEnvironment import Box
from SpiffWorkflow.bpmn.PythonScriptEngineEnvironment import BoxedTaskDataEnvironment from SpiffWorkflow.bpmn.PythonScriptEngineEnvironment import BoxedTaskDataEnvironment
from SpiffWorkflow.bpmn.serializer.helpers.registry import DefaultRegistry # type: ignore
from SpiffWorkflow.bpmn.serializer.task_spec import ( # type: ignore from SpiffWorkflow.bpmn.serializer.task_spec import ( # type: ignore
EventBasedGatewayConverter, EventBasedGatewayConverter,
) )
@ -688,14 +689,24 @@ class ProcessInstanceProcessor:
"lane_assignment_id": lane_assignment_id, "lane_assignment_id": lane_assignment_id,
} }
def spiff_step_details_mapping(self) -> dict: def spiff_step_details_mapping(self, spiff_task: Optional[SpiffTask]=None) -> dict:
"""SaveSpiffStepDetails.""" """SaveSpiffStepDetails."""
# bpmn_json = self.serialize() # bpmn_json = self.serialize()
# wf_json = json.loads(bpmn_json) # wf_json = json.loads(bpmn_json)
default_registry = DefaultRegistry()
if spiff_task is None:
# TODO: safer to pass in task vs use last task?
spiff_task = self.bpmn_process_instance.last_task
task_data = default_registry.convert(spiff_task.data)
python_env = default_registry.convert(self._script_engine.environment.last_result())
task_json: Dict[str, Any] = { task_json: Dict[str, Any] = {
# "tasks": wf_json["tasks"], # "tasks": wf_json["tasks"],
# "subprocesses": wf_json["subprocesses"], # "subprocesses": wf_json["subprocesses"],
# "python_env": self._script_engine.environment.last_result(), "task_data": task_data,
"python_env": python_env,
} }
return { return {
@ -1521,7 +1532,7 @@ class ProcessInstanceProcessor:
def did_complete_task(task: SpiffTask) -> None: def did_complete_task(task: SpiffTask) -> None:
if should_log(task): if should_log(task):
self._script_engine.environment.revise_state_with_task_data(task) self._script_engine.environment.revise_state_with_task_data(task)
step_details.append(self.spiff_step_details_mapping()) step_details.append(self.spiff_step_details_mapping(task))
try: try:
self.bpmn_process_instance.refresh_waiting_tasks() self.bpmn_process_instance.refresh_waiting_tasks()