handle inflight cases

FNNDSC · Mar 11, 2024 · 2c5ee9c · 2c5ee9c
1 parent 26d309b
commit 2c5ee9c
Show file tree

Hide file tree

Showing 3 changed files with 4 additions and 4 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.9.3"
+    version: str = "3.9.4"
     mongo_username: str = "admin"
     mongo_password: str = "admin"
     log_level: str = "DEBUG"

diff --git a/app/controllers/subprocesses/utils.py b/app/controllers/subprocesses/utils.py
@@ -48,7 +48,7 @@ def workflow_retrieve_helper(workflow: dict) -> WorkflowDBSchema:
         service_retry=workflow["service_retry"],
         stale=workflow["stale"],
         started=workflow["started"],
-        feed_requested=False if not workflow.get("feed_requested") else workflow["feed_requested"],
+        feed_requested= False if "feed_requested" not in workflow else workflow["feed_requested"]
     )
 
 

diff --git a/app/controllers/subprocesses/wf_manager.py b/app/controllers/subprocesses/wf_manager.py
@@ -97,9 +97,9 @@ def manage_workflow(db_key: str, test: bool):
 
                 case State.REGISTERING:
                     logger.info(f"Registering progress is {workflow.response.state_progress} complete.", extra=d)
+                    logger.info(f"Current feed request status is {workflow.feed_requested}", extra=d)
 
-                    if workflow.response.state_progress == "100%" and pl_inst_id==0:
-                        logger.info(f"Previous plugin instance ID is {pl_inst_id}", extra=d)
+                    if workflow.response.state_progress == "100%" and not workflow.feed_requested:
                         try:
                             resp = do_cube_create_feed(request, cube_url, workflow.service_retry)
                             pl_inst_id = resp["pl_inst_id"]