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

some more attempts to get reset working

This commit is contained in:
jasquat 2023-03-28 08:23:09 -04:00
parent e0cac8985f
commit d2f1ca1492
No known key found for this signature in database
3 changed files with 123 additions and 55 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -1,4 +1,5 @@
"""Process_instance_processor.""" """Process_instance_processor."""
import copy
import _strptime # type: ignore import _strptime # type: ignore
from sqlalchemy import or_ from sqlalchemy import or_
from sqlalchemy import and_ from sqlalchemy import and_
@ -1346,7 +1347,12 @@ class ProcessInstanceProcessor:
db.session.commit() db.session.commit()
for task_to_update in tasks_to_update: for task_to_update in tasks_to_update:
# print(f"task_to_update: {task_to_update}")
TaskService.reset_task_model(task_to_update, state="FUTURE", commit=commit) TaskService.reset_task_model(task_to_update, state="FUTURE", commit=commit)
# if task_to_update.task_definition.bpmn_identifier != 'top_level_process_script_after_gate':
# TaskService.reset_task_model(task_to_update, state='FUTURE', commit=commit)
# else:
# TaskService.reset_task_model(task_to_update, state=task_to_update.state, commit=commit)
parent_task_model = TaskModel.query.filter_by(guid=to_task_model.properties_json["parent"]).first() parent_task_model = TaskModel.query.filter_by(guid=to_task_model.properties_json["parent"]).first()
if parent_task_model is None: if parent_task_model is None:
@ -1364,6 +1370,13 @@ class ProcessInstanceProcessor:
for task_model in task_models_of_parent_bpmn_processes: for task_model in task_models_of_parent_bpmn_processes:
TaskService.reset_task_model(task_model, state="WAITING", commit=commit) TaskService.reset_task_model(task_model, state="WAITING", commit=commit)
bpmn_process = to_task_model.bpmn_process
properties_json = copy.copy(bpmn_process.properties_json)
properties_json['last_task'] = parent_task_model.guid
bpmn_process.properties_json = properties_json
db.session.add(bpmn_process)
db.session.commit()
if commit: if commit:
processor = ProcessInstanceProcessor(process_instance) processor = ProcessInstanceProcessor(process_instance)
processor.save() processor.save()

3
spiffworkflow-backend/src/spiffworkflow_backend/services/task_service.py
View File

@ -1,3 +1,4 @@
import copy
import json import json
from hashlib import sha256 from hashlib import sha256
from typing import Optional from typing import Optional
@ -360,7 +361,7 @@ class TaskService:
else: else:
task_model.python_env_data_hash = python_env_data_hash task_model.python_env_data_hash = python_env_data_hash
new_properties_json = task_model.properties_json new_properties_json = copy.copy(task_model.properties_json)
task_model.state = state task_model.state = state
task_model.start_in_seconds = None task_model.start_in_seconds = None
task_model.end_in_seconds = None task_model.end_in_seconds = None

162
spiffworkflow-backend/tests/spiffworkflow_backend/unit/test_process_instance_processor.py
View File

@ -256,60 +256,114 @@ class TestProcessInstanceProcessor(BaseTest):
assert spiff_task is not None assert spiff_task is not None
assert spiff_task.state == TaskState.COMPLETED assert spiff_task.state == TaskState.COMPLETED
# TODO: FIX resetting a process instance to a task def test_properly_resets_process_to_given_task(
# def test_properly_resets_process_to_given_task( self,
# self, app: Flask,
# app: Flask, client: FlaskClient,
# client: FlaskClient, with_db_and_bpmn_file_cleanup: None,
# with_db_and_bpmn_file_cleanup: None, with_super_admin_user: UserModel,
# with_super_admin_user: UserModel, ) -> None:
# ) -> None: self.create_process_group_with_api(client, with_super_admin_user, "test_group", "test_group")
# self.create_process_group_with_api(client, with_super_admin_user, "test_group", "test_group") initiator_user = self.find_or_create_user("initiator_user")
# initiator_user = self.find_or_create_user("initiator_user") finance_user_three = self.find_or_create_user("testuser3")
# finance_user_three = self.find_or_create_user("testuser3") assert initiator_user.principal is not None
# assert initiator_user.principal is not None assert finance_user_three.principal is not None
# assert finance_user_three.principal is not None AuthorizationService.import_permissions_from_yaml_file()
# AuthorizationService.import_permissions_from_yaml_file()
# finance_group = GroupModel.query.filter_by(identifier="Finance Team").first()
# finance_group = GroupModel.query.filter_by(identifier="Finance Team").first() assert finance_group is not None
# assert finance_group is not None
# process_model = load_test_spec(
# process_model = load_test_spec( process_model_id="test_group/manual_task",
# process_model_id="test_group/manual_task_with_subprocesses", process_model_source_directory="manual_task",
# process_model_source_directory="manual_task_with_subprocesses", )
# ) process_instance = self.create_process_instance_from_process_model(
# process_instance = self.create_process_instance_from_process_model( process_model=process_model, user=initiator_user
# process_model=process_model, user=initiator_user )
# ) processor = ProcessInstanceProcessor(process_instance)
# processor = ProcessInstanceProcessor(process_instance) processor.do_engine_steps(save=True)
# processor.do_engine_steps(save=True) assert len(process_instance.active_human_tasks) == 1
# assert len(process_instance.active_human_tasks) == 1 initial_human_task_id = process_instance.active_human_tasks[0].id
# initial_human_task_id = process_instance.active_human_tasks[0].id
# # save again to ensure we go attempt to process the human tasks again
# # save again to ensure we go attempt to process the human tasks again processor.save()
# processor.save()
# assert len(process_instance.active_human_tasks) == 1
# assert len(process_instance.active_human_tasks) == 1 assert initial_human_task_id == process_instance.active_human_tasks[0].id
# assert initial_human_task_id == process_instance.active_human_tasks[0].id
# processor = ProcessInstanceProcessor(process_instance)
# processor = ProcessInstanceProcessor(process_instance) human_task_one = process_instance.active_human_tasks[0]
# human_task_one = process_instance.active_human_tasks[0] spiff_manual_task = processor.__class__.get_task_by_bpmn_identifier(
# spiff_manual_task = processor.__class__.get_task_by_bpmn_identifier( human_task_one.task_name, processor.bpmn_process_instance
# human_task_one.task_name, processor.bpmn_process_instance )
# )
# ProcessInstanceService.complete_form_task(processor, spiff_manual_task, {}, initiator_user, human_task_one) processor.suspend()
# ProcessInstanceProcessor.reset_process(process_instance, str(spiff_manual_task.parent.id), commit=True)
# processor.suspend()
# ProcessInstanceProcessor.reset_process(process_instance, str(spiff_manual_task.id), commit=True) process_instance = ProcessInstanceModel.query.filter_by(id=process_instance.id).first()
# processor = ProcessInstanceProcessor(process_instance)
# process_instance = ProcessInstanceModel.query.filter_by(id=process_instance.id).first() processor.resume()
# processor = ProcessInstanceProcessor(process_instance) processor.do_engine_steps(save=True)
# human_task_one = process_instance.active_human_tasks[0] human_task_one = process_instance.active_human_tasks[0]
# spiff_manual_task = processor.bpmn_process_instance.get_task(UUID(human_task_one.task_id)) spiff_manual_task = processor.bpmn_process_instance.get_task(UUID(human_task_one.task_id))
# ProcessInstanceService.complete_form_task(processor, spiff_manual_task, {}, initiator_user, human_task_one) ProcessInstanceService.complete_form_task(processor, spiff_manual_task, {}, initiator_user, human_task_one)
# human_task_one = process_instance.active_human_tasks[0] assert process_instance.status == "complete"
# spiff_manual_task = processor.bpmn_process_instance.get_task(UUID(human_task_one.task_id))
# ProcessInstanceService.complete_form_task(processor, spiff_manual_task, {}, initiator_user, human_task_one) def test_properly_resets_process_to_given_task_with_call_activity(
self,
app: Flask,
client: FlaskClient,
with_db_and_bpmn_file_cleanup: None,
with_super_admin_user: UserModel,
) -> None:
self.create_process_group_with_api(client, with_super_admin_user, "test_group", "test_group")
initiator_user = self.find_or_create_user("initiator_user")
finance_user_three = self.find_or_create_user("testuser3")
assert initiator_user.principal is not None
assert finance_user_three.principal is not None
AuthorizationService.import_permissions_from_yaml_file()
finance_group = GroupModel.query.filter_by(identifier="Finance Team").first()
assert finance_group is not None
process_model = load_test_spec(
process_model_id="test_group/manual_task_with_subprocesses",
process_model_source_directory="manual_task_with_subprocesses",
)
process_instance = self.create_process_instance_from_process_model(
process_model=process_model, user=initiator_user
)
processor = ProcessInstanceProcessor(process_instance)
processor.do_engine_steps(save=True)
import pdb; pdb.set_trace()
assert len(process_instance.active_human_tasks) == 1
initial_human_task_id = process_instance.active_human_tasks[0].id
# save again to ensure we go attempt to process the human tasks again
processor.save()
assert len(process_instance.active_human_tasks) == 1
assert initial_human_task_id == process_instance.active_human_tasks[0].id
processor = ProcessInstanceProcessor(process_instance)
human_task_one = process_instance.active_human_tasks[0]
spiff_manual_task = processor.__class__.get_task_by_bpmn_identifier(
human_task_one.task_name, processor.bpmn_process_instance
)
processor.suspend()
ProcessInstanceProcessor.reset_process(process_instance, str(spiff_manual_task.parent.id), commit=True)
import pdb; pdb.set_trace()
process_instance = ProcessInstanceModel.query.filter_by(id=process_instance.id).first()
processor = ProcessInstanceProcessor(process_instance)
processor.resume()
processor.do_engine_steps(save=True)
import pdb; pdb.set_trace()
human_task_one = process_instance.active_human_tasks[0]
spiff_manual_task = processor.bpmn_process_instance.get_task(UUID(human_task_one.task_id))
ProcessInstanceService.complete_form_task(processor, spiff_manual_task, {}, initiator_user, human_task_one)
assert process_instance.status == "complete"
def test_properly_saves_tasks_when_running( def test_properly_saves_tasks_when_running(
self, self,