from flows.base_flows import SequentialFlow class CF_CodeDebugCriticWithPlan(SequentialFlow): def __init__(self, **kwargs): super().__init__(**kwargs) def _early_exit(self): if self.flow_state.get("all_tests_passed", False): self.flow_state["code_feedback"] = None return True return super()._early_exit()