Added delete_files argument to the restart_workflow api method, and pass it along to WorkflowProcessor.reset

This commit is contained in:
mike cullerton 2021-04-15 11:23:20 -04:00
parent 4615649938
commit 3332b9c7c0

View File

@ -116,11 +116,11 @@ def get_workflow(workflow_id, do_engine_steps=True):
return WorkflowApiSchema().dump(workflow_api_model)
def restart_workflow(workflow_id, clear_data=False):
def restart_workflow(workflow_id, clear_data=False, delete_files=False):
"""Restart a workflow with the latest spec.
Clear data allows user to restart the workflow without previous data."""
workflow_model: WorkflowModel = session.query(WorkflowModel).filter_by(id=workflow_id).first()
WorkflowProcessor.reset(workflow_model, clear_data=clear_data)
WorkflowProcessor.reset(workflow_model, clear_data=clear_data, delete_files=delete_files)
return get_workflow(workflow_model.id)