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

Fixing formatting?

This commit is contained in:
Dan 2023-04-20 17:05:05 -04:00
parent 259290846d
commit 3d235e0c8e
1 changed files with 5 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
spiffworkflow-backend/src/spiffworkflow_backend/services/process_instance_service.py
View File

@ -115,14 +115,13 @@ class ProcessInstanceService:
.filter(ProcessInstanceModel.id.in_(process_instance_ids_to_check)) # type: ignore
.all()
)
execution_strategy_name = current_app.config[
"SPIFFWORKFLOW_BACKEND_ENGINE_STEP_DEFAULT_STRATEGY_BACKGROUND"
]
execution_strategy_name = current_app.config["SPIFFWORKFLOW_BACKEND_ENGINE_STEP_DEFAULT_STRATEGY_BACKGROUND"]
for process_instance in records:
current_app.logger.info(f"Processing process_instance {process_instance.id}")
try:
cls.run_process_instance_with_processor(process_instance, status_value=status_value,
execution_strategy_name=execution_strategy_name)
cls.run_process_instance_with_processor(
process_instance, status_value=status_value, execution_strategy_name=execution_strategy_name
)
except ProcessInstanceIsAlreadyLockedError:
continue
except Exception as e:
@ -135,8 +134,7 @@ class ProcessInstanceService:
@classmethod
def run_process_instance_with_processor(
cls, process_instance: ProcessInstanceModel, status_value: Optional[str] = None,
execution_strategy_name = None
cls, process_instance: ProcessInstanceModel, status_value: Optional[str] = None, execution_strategy_name=None
) -> Optional[ProcessInstanceProcessor]:
processor = None
with ProcessInstanceQueueService.dequeued(process_instance):