Update UpdatePlanAtomicFlow.py
Browse files- UpdatePlanAtomicFlow.py +10 -0
UpdatePlanAtomicFlow.py
CHANGED
|
@@ -2,6 +2,16 @@
|
|
| 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 flow updates the plan file with the updated plan. The controller should pass the updated plan to this flow.
|
| 6 |
+
This design (controller reflect on the existing plan--update plan) is intended to let the controller more aware of the
|
| 7 |
+
plan it has. However one setback is that this process in then not deterministic.
|
| 8 |
+
|
| 9 |
+
*Input Interface*
|
| 10 |
+
- `updated_plan`: the updated plan in string format
|
| 11 |
+
|
| 12 |
+
*Output Interface*
|
| 13 |
+
- `result`: the result of the update plan operation
|
| 14 |
+
"""
|
| 15 |
def _check_input(self, input_data: Dict[str, Any]):
|
| 16 |
assert "memory_files" in input_data, "memory_files not passed to UpdatePlanAtomicFlow.yaml"
|
| 17 |
assert "plan" in input_data["memory_files"], "plan not in memory_files"
|