Spaces:
Sleeping
Sleeping
Update app.py
Browse files
app.py
CHANGED
@@ -2044,7 +2044,7 @@ def plan_opcode_counter_node(state: Dict[str, Any]) -> Dict[str, Any]:
|
|
2044 |
# Invoke the main agent for logic refinement and relationship identification
|
2045 |
response = agent.invoke({"messages": [{"role": "user", "content": refinement_prompt}]})
|
2046 |
llm_output = response["messages"][-1].content
|
2047 |
-
print(f"[RAW RESPONSE OPCODE COUTER LOGIC]: {response}")
|
2048 |
llm_json = extract_json_from_llm_response(llm_output)
|
2049 |
logger.info(f"Successfully analyse the opcode requirement for {sprite} - {event}.")
|
2050 |
|
@@ -3665,12 +3665,12 @@ workflow.add_node("time_delay_3", delay_for_tpm_node) # this is a temporary node
|
|
3665 |
workflow.add_node("time_delay_4", delay_for_tpm_node) # this is a temporary node to handle TPM issues
|
3666 |
workflow.add_node("time_delay_5", delay_for_tpm_node) # this is a temporary node to handle TPM issues
|
3667 |
workflow.add_node("time_delay_6", delay_for_tpm_node) # this is a temporary node to handle TPM issues
|
3668 |
-
workflow.add_node("time_delay_7", delay_for_tpm_node) # this is a temporary node to handle TPM issues
|
3669 |
workflow.add_node("initial_plan_build", overall_planner_node) # High-level planning node
|
3670 |
workflow.add_node("logic_alignment", plan_logic_aligner_node)
|
3671 |
workflow.add_node("plan_verifier", plan_verification_node)
|
3672 |
workflow.add_node("refined_planner", refined_planner_node) # Refines the action plan
|
3673 |
-
workflow.add_node("opcode_counter", plan_opcode_counter_node)
|
3674 |
workflow.add_node("relation_builder", block_relationship_node)
|
3675 |
# Verifies the high-level plan
|
3676 |
workflow.add_node("block_builder", overall_block_builder_node) # Builds blocks from a plan
|
@@ -3698,24 +3698,22 @@ def decide_next_step_after_plan_verification(state: GameState):
|
|
3698 |
return "refined_planner"
|
3699 |
else:
|
3700 |
# If the plan is good, proceed to building blocks from this plan
|
3701 |
-
return "
|
3702 |
|
3703 |
workflow.add_conditional_edges(
|
3704 |
"plan_verifier",
|
3705 |
decide_next_step_after_plan_verification,
|
3706 |
{
|
3707 |
"refined_planner": "refined_planner", # Path if plan needs refinement
|
3708 |
-
"
|
3709 |
}
|
3710 |
)
|
3711 |
# --- CRITICAL CHANGE FOR THE PLAN REFINEMENT LOOP ---
|
3712 |
# After refining the plan, it should go back to plan_verifier for re-verification.
|
3713 |
workflow.add_edge("refined_planner", "time_delay_5")
|
3714 |
workflow.add_edge("time_delay_5", "plan_verifier") # This closes the loop for plan refinement and re-verification.
|
3715 |
-
workflow.add_edge("
|
3716 |
-
workflow.add_edge("time_delay_6", "
|
3717 |
-
workflow.add_edge("relation_builder", "time_delay_7")
|
3718 |
-
workflow.add_edge("time_delay_7", "block_builder")
|
3719 |
workflow.add_edge("block_builder", END)
|
3720 |
# Note: The original code had workflow.add_edge("time_delay", "block_builder") here,
|
3721 |
# but after refined_planner -> time_delay -> plan_verifier, the decision is made by plan_verifier.
|
|
|
2044 |
# Invoke the main agent for logic refinement and relationship identification
|
2045 |
response = agent.invoke({"messages": [{"role": "user", "content": refinement_prompt}]})
|
2046 |
llm_output = response["messages"][-1].content
|
2047 |
+
#print(f"[RAW RESPONSE OPCODE COUTER LOGIC]: {response}")
|
2048 |
llm_json = extract_json_from_llm_response(llm_output)
|
2049 |
logger.info(f"Successfully analyse the opcode requirement for {sprite} - {event}.")
|
2050 |
|
|
|
3665 |
workflow.add_node("time_delay_4", delay_for_tpm_node) # this is a temporary node to handle TPM issues
|
3666 |
workflow.add_node("time_delay_5", delay_for_tpm_node) # this is a temporary node to handle TPM issues
|
3667 |
workflow.add_node("time_delay_6", delay_for_tpm_node) # this is a temporary node to handle TPM issues
|
3668 |
+
#workflow.add_node("time_delay_7", delay_for_tpm_node) # this is a temporary node to handle TPM issues
|
3669 |
workflow.add_node("initial_plan_build", overall_planner_node) # High-level planning node
|
3670 |
workflow.add_node("logic_alignment", plan_logic_aligner_node)
|
3671 |
workflow.add_node("plan_verifier", plan_verification_node)
|
3672 |
workflow.add_node("refined_planner", refined_planner_node) # Refines the action plan
|
3673 |
+
#workflow.add_node("opcode_counter", plan_opcode_counter_node)
|
3674 |
workflow.add_node("relation_builder", block_relationship_node)
|
3675 |
# Verifies the high-level plan
|
3676 |
workflow.add_node("block_builder", overall_block_builder_node) # Builds blocks from a plan
|
|
|
3698 |
return "refined_planner"
|
3699 |
else:
|
3700 |
# If the plan is good, proceed to building blocks from this plan
|
3701 |
+
return "relation_builder"#"block_builder"
|
3702 |
|
3703 |
workflow.add_conditional_edges(
|
3704 |
"plan_verifier",
|
3705 |
decide_next_step_after_plan_verification,
|
3706 |
{
|
3707 |
"refined_planner": "refined_planner", # Path if plan needs refinement
|
3708 |
+
"relation_builder": "relation_builder"#"block_builder": "block_builder" # Path if plan is approved, proceeds to block building
|
3709 |
}
|
3710 |
)
|
3711 |
# --- CRITICAL CHANGE FOR THE PLAN REFINEMENT LOOP ---
|
3712 |
# After refining the plan, it should go back to plan_verifier for re-verification.
|
3713 |
workflow.add_edge("refined_planner", "time_delay_5")
|
3714 |
workflow.add_edge("time_delay_5", "plan_verifier") # This closes the loop for plan refinement and re-verification.
|
3715 |
+
workflow.add_edge("relation_builder", "time_delay_6")
|
3716 |
+
workflow.add_edge("time_delay_6", "block_builder")
|
|
|
|
|
3717 |
workflow.add_edge("block_builder", END)
|
3718 |
# Note: The original code had workflow.add_edge("time_delay", "block_builder") here,
|
3719 |
# but after refined_planner -> time_delay -> plan_verifier, the decision is made by plan_verifier.
|