Update WritePlanFlow.py

WritePlanFlow.py

@@ -1,6 +1,7 @@
 from typing import Dict, Any
 
 from flows.base_flows import SequentialFlow
+from flows.base_flows import CircularFlow
 from flows.utils import logging
 from .PlanGeneratorAtomicFlow import PlanGeneratorAtomicFlow
 
@@ -8,12 +9,4 @@ logging.set_verbosity_debug()
 log = logging.get_logger(__name__)
 
 class WritePlanFlow(SequentialFlow):
-    @SequentialFlow.output_msg_payload_processor
-    def detect_finish_or_continue(self, output_payload: Dict[str, Any], src_flow: PlanGeneratorAtomicFlow) -> Dict[str, Any]:
-        if "plan" not in output_payload:
-            return {
-                "EARLY_EXIT": True,
-                "plan_writer_output": output_payload
-            }
-        else:
-            return output_payload
+    pass