sartography
/
cr-connect-workflow
mirror of https://github.com/sartography/cr-connect-workflow.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

exit at task

This commit is contained in:
NWalker4483 2021-06-09 12:40:38 -04:00
parent ef7ee284b2
commit 17077be701
2 changed files with 24 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

15
.vscode/launch.json vendored Normal file
View File

@ -0,0 +1,15 @@
{
// Use IntelliSense to learn about possible attributes.
// Hover to view descriptions of existing attributes.
// For more information, visit: https://go.microsoft.com/fwlink/?linkid=830387
"version": "0.2.0",
"configurations": [
{
"name": "Python: Current File",
"type": "python",
"request": "launch",
"program": "run.py",
"console": "integratedTerminal"
}
]
}

10
crc/services/workflow_service.py
View File

@ -80,13 +80,15 @@ class WorkflowService(object):
db.session.delete(user) db.session.delete(user)
@staticmethod @staticmethod
def test_spec(spec_id, required_only=False): def test_spec(spec_id, required_only=False, test_until = ""):
"""Runs a spec through it's paces to see if it results in any errors. """Runs a spec through it's paces to see if it results in any errors.
Not fool-proof, but a good sanity check. Returns the final data Not fool-proof, but a good sanity check. Returns the final data
output form the last task if successful. output form the last task if successful.
required_only can be set to true, in which case this will run the required_only can be set to true, in which case this will run the
spec, only completing the required fields, rather than everything. spec, only completing the required fields, rather than everything.
testing_depth
""" """
workflow_model = WorkflowService.make_test_workflow(spec_id) workflow_model = WorkflowService.make_test_workflow(spec_id)
@ -98,6 +100,7 @@ class WorkflowService(object):
raise ApiError.from_workflow_exception("workflow_validation_exception", str(we), we) raise ApiError.from_workflow_exception("workflow_validation_exception", str(we), we)
count = 0 count = 0
while not processor.bpmn_workflow.is_completed(): while not processor.bpmn_workflow.is_completed():
if count < 100: # check for infinite loop if count < 100: # check for infinite loop
try: try:
@ -121,6 +124,11 @@ class WorkflowService(object):
task_name=task.get_name()) task_name=task.get_name())
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)
a = task.get_data()
if test_until == task.name:
test_data = processor.bpmn_workflow.last_task.data
WorkflowService.delete_test_data()
return test_data
count += 1 count += 1
except WorkflowException as we: except WorkflowException as we:
WorkflowService.delete_test_data() WorkflowService.delete_test_data()