Update UpdatePlanAtomicFlow.py
Browse files- UpdatePlanAtomicFlow.py +4 -0
UpdatePlanAtomicFlow.py
CHANGED
|
@@ -2,6 +2,10 @@
|
|
| 2 |
from typing import Dict, Any
|
| 3 |
from aiflows.base_flows.atomic import AtomicFlow
|
| 4 |
class UpdatePlanAtomicFlow(AtomicFlow):
|
|
|
|
|
|
|
|
|
|
|
|
|
| 5 |
def _check_input(self, input_data: Dict[str, Any]):
|
| 6 |
assert "memory_files" in input_data, "memory_files not passed to UpdatePlanAtomicFlow.yaml"
|
| 7 |
assert "plan" in input_data["memory_files"], "plan not in memory_files"
|
|
|
|
| 2 |
from typing import Dict, Any
|
| 3 |
from aiflows.base_flows.atomic import AtomicFlow
|
| 4 |
class UpdatePlanAtomicFlow(AtomicFlow):
|
| 5 |
+
"""This class is used to update the plan file with the updated plan, called by the controlller,
|
| 6 |
+
when it realizes one step of the plan is done, and provide the updated plan, it is exactly the same
|
| 7 |
+
as the old plan, except the step that is done is marked as done.
|
| 8 |
+
"""
|
| 9 |
def _check_input(self, input_data: Dict[str, Any]):
|
| 10 |
assert "memory_files" in input_data, "memory_files not passed to UpdatePlanAtomicFlow.yaml"
|
| 11 |
assert "plan" in input_data["memory_files"], "plan not in memory_files"
|