Update PlanWriterFlow.py

PlanWriterFlow.py

@@ -59,4 +59,20 @@ class PlanWriterFlow(ContentWriterFlow):
             output_payload["command_args"]["plan_file_location"] = plan_file_location
             return output_payload
         else:
-            return output_payload
+            return output_payload
+
+    def run(self, input_data: Dict[str, Any]) -> Dict[str, Any]:
+        # ~~~ sets the input_data in the flow_state dict ~~~
+        self._state_update_dict(update_data=input_data)
+
+        max_rounds = self.flow_config.get("max_rounds", 1)
+        if max_rounds is None:
+            log.info(f"Running {self.flow_config['name']} without `max_rounds` until the early exit condition is met.")
+
+        self._sequential_run(max_rounds=max_rounds)
+
+        output = self._get_output_from_state()
+
+        self.reset(full_reset=True, recursive=True, src_flow=self)
+
+        return output