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}')