fixed_reply.py

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"]}