Skip to content

Commit

Permalink
fixed duplicate feed issue
Browse files Browse the repository at this point in the history
  • Loading branch information
Sandip117 committed Feb 2, 2024
1 parent de6b5f2 commit a216c85
Showing 1 changed file with 2 additions and 2 deletions.
4 changes: 2 additions & 2 deletions app/controllers/subprocesses/wf_manager.py
Original file line number Diff line number Diff line change
Expand Up @@ -95,7 +95,7 @@ def manage_workflow(db_key: str, test: bool):
case State.REGISTERING:
logger.info(f"Registering progress is {workflow.response.state_progress} complete.", extra=d)

if workflow.response.state_progress == "100%" and workflow.stale:
if workflow.response.state_progress == "100%" and workflow.stale and not workflow.response.feed_id:
try:
resp = do_cube_create_feed(request, cube_url, workflow.service_retry)
pl_inst_id = resp["pl_inst_id"]
Expand Down Expand Up @@ -170,7 +170,7 @@ def update_status(request: WorkflowRequestSchema):
d_data = request_to_dict(request)
str_data = json.dumps(d_data)
proc_count = get_process_count("app/controllers/subprocesses/status.py", str_data)
logger.debug(f"{proc_count} subprocess of status manager running on the system.", extra=d)
logger.info(f"{proc_count} subprocess of status manager running on the system.", extra=d)
if proc_count > 0:
logger.info(f"No new status subprocess started.", extra=d)
return
Expand Down

0 comments on commit a216c85

Please sign in to comment.