mirror of
https://github.com/sartography/spiffworkflow-backend.git
synced 2025-02-23 21:08:18 +00:00
Merge branch 'main' into feature/nested-groups-2
# Conflicts: # spiffworkflow-frontend/src/routes/ProcessGroupShow.tsx
This commit is contained in:
commit
dfa79360c4
@ -413,7 +413,7 @@ paths:
|
|||||||
- name: process_status
|
- name: process_status
|
||||||
in: query
|
in: query
|
||||||
required: false
|
required: false
|
||||||
description: For filtering - not_started, user_input_required, waiting, complete, faulted, or suspended
|
description: For filtering - not_started, user_input_required, waiting, complete, error, or suspended
|
||||||
schema:
|
schema:
|
||||||
type: string
|
type: string
|
||||||
# process_instance_list
|
# process_instance_list
|
||||||
|
@ -60,10 +60,9 @@ class ProcessInstanceStatus(SpiffEnum):
|
|||||||
user_input_required = "user_input_required"
|
user_input_required = "user_input_required"
|
||||||
waiting = "waiting"
|
waiting = "waiting"
|
||||||
complete = "complete"
|
complete = "complete"
|
||||||
faulted = "faulted"
|
error = "error"
|
||||||
suspended = "suspended"
|
suspended = "suspended"
|
||||||
terminated = "terminated"
|
terminated = "terminated"
|
||||||
erroring = "erroring"
|
|
||||||
|
|
||||||
|
|
||||||
class ProcessInstanceModel(SpiffworkflowBaseDBModel):
|
class ProcessInstanceModel(SpiffworkflowBaseDBModel):
|
||||||
|
@ -82,10 +82,6 @@ class ProcessInstanceReportModel(SpiffworkflowBaseDBModel):
|
|||||||
report_metadata = {
|
report_metadata = {
|
||||||
"columns": [
|
"columns": [
|
||||||
{"Header": "id", "accessor": "id"},
|
{"Header": "id", "accessor": "id"},
|
||||||
{
|
|
||||||
"Header": "process_group_identifier",
|
|
||||||
"accessor": "process_group_identifier",
|
|
||||||
},
|
|
||||||
{
|
{
|
||||||
"Header": "process_model_identifier",
|
"Header": "process_model_identifier",
|
||||||
"accessor": "process_model_identifier",
|
"accessor": "process_model_identifier",
|
||||||
|
@ -23,7 +23,7 @@ def load_acceptance_test_fixtures() -> list[ProcessInstanceModel]:
|
|||||||
# user_input_required - 2 hours ago
|
# user_input_required - 2 hours ago
|
||||||
# waiting - 3 hourse ago
|
# waiting - 3 hourse ago
|
||||||
# complete - 4 hours ago
|
# complete - 4 hours ago
|
||||||
# faulted - 5 hours ago
|
# error - 5 hours ago
|
||||||
# suspended - 6 hours ago
|
# suspended - 6 hours ago
|
||||||
process_instances = []
|
process_instances = []
|
||||||
for i in range(len(statuses)):
|
for i in range(len(statuses)):
|
||||||
|
@ -45,7 +45,7 @@ class ErrorHandlingService:
|
|||||||
# fault is the default
|
# fault is the default
|
||||||
self.set_instance_status(
|
self.set_instance_status(
|
||||||
_processor.process_instance_model.id,
|
_processor.process_instance_model.id,
|
||||||
ProcessInstanceStatus.faulted.value,
|
ProcessInstanceStatus.error.value,
|
||||||
)
|
)
|
||||||
|
|
||||||
if len(process_model.exception_notification_addresses) > 0:
|
if len(process_model.exception_notification_addresses) > 0:
|
||||||
|
@ -63,7 +63,7 @@ class ProcessInstanceService:
|
|||||||
processor.do_engine_steps(save=True)
|
processor.do_engine_steps(save=True)
|
||||||
except Exception as e:
|
except Exception as e:
|
||||||
db.session.rollback() # in case the above left the database with a bad transaction
|
db.session.rollback() # in case the above left the database with a bad transaction
|
||||||
process_instance.status = ProcessInstanceStatus.erroring.value
|
process_instance.status = ProcessInstanceStatus.error.value
|
||||||
db.session.add(process_instance)
|
db.session.add(process_instance)
|
||||||
db.session.commit()
|
db.session.commit()
|
||||||
error_message = (
|
error_message = (
|
||||||
|
@ -1715,7 +1715,7 @@ class TestProcessApi(BaseTest):
|
|||||||
.first()
|
.first()
|
||||||
)
|
)
|
||||||
assert process is not None
|
assert process is not None
|
||||||
assert process.status == "faulted"
|
assert process.status == "error"
|
||||||
|
|
||||||
def test_error_handler_suspend(
|
def test_error_handler_suspend(
|
||||||
self,
|
self,
|
||||||
@ -1826,7 +1826,7 @@ class TestProcessApi(BaseTest):
|
|||||||
.first()
|
.first()
|
||||||
)
|
)
|
||||||
assert process is not None
|
assert process is not None
|
||||||
assert process.status == "faulted"
|
assert process.status == "error"
|
||||||
|
|
||||||
def test_process_model_file_create(
|
def test_process_model_file_create(
|
||||||
self,
|
self,
|
||||||
|
Loading…
x
Reference in New Issue
Block a user