sartography/cr-connect-workflow
1
0
Fork 0
mirror of https://github.com/sartography/cr-connect-workflow.git synced 2025-02-22 04:38:21 +00:00
Code Issues Packages Projects Releases Wiki Activity

Added Partial Workflow spec

Browse Source
This commit is contained in:
NWalker4483 2021-06-09 15:21:21 -04:00
parent 2364c240b2
commit e1a4a79b03
1 changed files with 5 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
crc/services/workflow_service.py
View File

@ -121,8 +121,8 @@ class WorkflowService(object):
if (exit_task != None): if (exit_task != None):
WorkflowService.delete_test_data() WorkflowService.delete_test_data()
raise ApiError.from_task("validation_break", raise ApiError.from_task("validation_break",
f"This task is called '{task.task_spec.name}' and was run using " f"The validation has been exited early on task '{exit_task.task_spec.name}' and was parented by ",
, exit_task.parent) exit_task.parent)
tasks = processor.bpmn_workflow.get_tasks(SpiffTask.READY) tasks = processor.bpmn_workflow.get_tasks(SpiffTask.READY)
for task in tasks: for task in tasks:
if task.task_spec.lane is not None and task.task_spec.lane not in task.data: if task.task_spec.lane is not None and task.task_spec.lane not in task.data:
@ -142,10 +142,10 @@ class WorkflowService(object):
WorkflowService.populate_form_with_random_data(task, task_api, required_only) WorkflowService.populate_form_with_random_data(task, task_api, required_only)
processor.complete_task(task) processor.complete_task(task)
if test_until == task.task_spec.name: if test_until == task.task_spec.name:
escaped = WorkflowService.delete_test_data() WorkflowService.delete_test_data()
raise ApiError.from_task("validation_break", raise ApiError.from_task("validation_break",
f"This task is called '{task.task_spec.name}' and was run using " f"The validation has been exited early on task '{task.task_spec.name}' and was parented by ",
, task.parent) task.parent)
count += 1 count += 1
except WorkflowException as we: except WorkflowException as we:
WorkflowService.delete_test_data() WorkflowService.delete_test_data()