From 0d7b26423cf798d3b9b59ec03139a8cd1f525555 Mon Sep 17 00:00:00 2001 From: mike cullerton Date: Fri, 29 Apr 2022 17:40:30 -0400 Subject: [PATCH] *** WIP *** Skeleton for updating the workflows in a separate call --- crc/api/study.py | 1 + crc/services/workflow_service.py | 5 ++++- 2 files changed, 5 insertions(+), 1 deletion(-) diff --git a/crc/api/study.py b/crc/api/study.py index 08fc403a..0e6d275c 100644 --- a/crc/api/study.py +++ b/crc/api/study.py @@ -111,6 +111,7 @@ def get_study(study_id, update_status=False): if update_status: study_model = session.query(StudyModel).filter(StudyModel.id == study_id).first() master_workflow_results = __run_master_spec(study_model, spec_service.master_spec) + WorkflowService().update_workflow_state_from_master_workflow(study_id, master_workflow_results) study = StudyService().get_study(study_id, categories, master_workflow_results=master_workflow_results, process_categories=True) if (study is None): raise ApiError("unknown_study", 'The study "' + study_id + '" is not recognized.', status_code=404) diff --git a/crc/services/workflow_service.py b/crc/services/workflow_service.py index 20f4d61d..7d6f7848 100755 --- a/crc/services/workflow_service.py +++ b/crc/services/workflow_service.py @@ -1127,4 +1127,7 @@ class WorkflowService(object): db.session.commit() return workflow_model - + def update_workflow_state_from_master_workflow(self, study_id, master_workflow_results): + workflows = session.query(WorkflowModel).filter(WorkflowModel.study_id == study_id).all() + for item in master_workflow_results: + print(f'update_workflow_state_from_master_workflow: item: {item}')