check no plan after checking user_goal_achieved (#1556)
This commit is contained in:
@@ -391,10 +391,6 @@ async def run_observer_cruise_helper(
|
|||||||
output={"task_type": task_type, "user_goal_achieved": user_goal_achieved},
|
output={"task_type": task_type, "user_goal_achieved": user_goal_achieved},
|
||||||
)
|
)
|
||||||
|
|
||||||
if not plan:
|
|
||||||
LOG.warning("No plan found in observer response", observer_response=observer_response)
|
|
||||||
continue
|
|
||||||
|
|
||||||
if user_goal_achieved is True:
|
if user_goal_achieved is True:
|
||||||
LOG.info(
|
LOG.info(
|
||||||
"User goal achieved. Workflow run will complete. Observer is stopping",
|
"User goal achieved. Workflow run will complete. Observer is stopping",
|
||||||
@@ -409,6 +405,10 @@ async def run_observer_cruise_helper(
|
|||||||
)
|
)
|
||||||
break
|
break
|
||||||
|
|
||||||
|
if not plan:
|
||||||
|
LOG.warning("No plan found in observer response", observer_response=observer_response)
|
||||||
|
continue
|
||||||
|
|
||||||
# parse observer repsonse and run the next task
|
# parse observer repsonse and run the next task
|
||||||
if not task_type:
|
if not task_type:
|
||||||
LOG.error("No task type found in observer response", observer_response=observer_response)
|
LOG.error("No task type found in observer response", observer_response=observer_response)
|
||||||
|
|||||||
Reference in New Issue
Block a user