| from typing import Dict, Any | |
| from flows.base_flows import AtomicFlow | |
| class FixedReplyFlow(AtomicFlow): | |
| REQUIRED_KEYS_CONFIG = ["fixed_reply"] | |
| __default_flow_config = { | |
| "input_interface": [], | |
| "output_interface": ["fixed_reply"], | |
| } | |
| def __init__(self, **kwargs): | |
| super().__init__(**kwargs) | |
| def run(self, | |
| input_data: Dict[str, Any]) -> Dict[str, Any]: | |
| return {"fixed_reply": self.flow_config["fixed_reply"]} | |