Keep workflow progress consistent with time

FNNDSC · Jul 21, 2023 · de2156a · de2156a
1 parent 5326d20
commit de2156a
Show file tree

Hide file tree

Showing 3 changed files with 4 additions and 3 deletions.
diff --git a/app/config.py b/app/config.py
@@ -3,7 +3,7 @@
 
 class Settings(BaseSettings):
     pflink_mongodb: MongoDsn = 'mongodb://localhost:27017'
-    version: str = "3.5.3"
+    version: str = "3.5.4"
 
 
 class Auth(BaseSettings):

diff --git a/app/controllers/subprocesses/status.py b/app/controllers/subprocesses/status.py
@@ -73,7 +73,9 @@ def update_workflow_progress(response: WorkflowStatusResponseSchema):
     for elem in State:
         if response.workflow_state == elem:
             state_progress = int(response.state_progress.replace('%',''))
-            response.workflow_progress_perc = __progress_percent(index,MAX_STATE,state_progress)
+
+            response.workflow_progress_perc = max(response.workflow_progress_perc,
+                                                  __progress_percent(index,MAX_STATE,state_progress))
         index += 1
     return response
 

diff --git a/app/controllers/subprocesses/wf_manager.py b/app/controllers/subprocesses/wf_manager.py
@@ -247,7 +247,6 @@ def __run_pipeline_instance(previous_id: str, request: WorkflowRequestSchema, cl
     """
     Run a workflow instance on an existing (previous) plugin instance ID in CUBE
     """
-    print(previous_id)
     # search for pipeline
     pipeline_search_params = {"name": request.workflow_info.pipeline_name}
     pipeline_id = client.getPipelineId(pipeline_search_params)