First commit.

HumanStandardInputFlow.py

@@ -0,0 +1,101 @@
+from copy import deepcopy
+from typing import Dict, Any
+
+import hydra
+from langchain import PromptTemplate
+
+from flows.base_flows import AtomicFlow
+from flows.messages import UpdateMessage_Generic
+
+from flows.utils import logging
+
+# logging.set_verbosity_debug()  # ToDo: Has no effect on the logger for __name__. Level is warn, and info is not printed
+log = logging.get_logger(f"flows.{__name__}")  # ToDo: Is there a better fix?
+
+
+class HumanStandardInputFlow(AtomicFlow):
+    REQUIRED_KEYS_CONFIG = ["request_multi_line_input_flag"]
+
+    query_message_prompt_template: PromptTemplate = None
+
+    __default_flow_config = {
+        "end_of_input_string": "EOI",
+        "input_keys": [],
+        "description": "Reads input from the user's standard input.",
+        "query_message_prompt_template": {
+            "_target_": "langchain.PromptTemplate",
+            "template": "",
+            "input_variables": [],
+            "partial_variables": {},
+            "template_format": "jinja2"
+        }
+    }
+
+    def __init__(self, query_message_prompt_template, **kwargs):
+        super().__init__(**kwargs)
+        self.query_message_prompt_template = query_message_prompt_template
+
+    @classmethod
+    def _set_up_prompts(cls, config):
+        kwargs = {}
+
+        kwargs["query_message_prompt_template"] = \
+            hydra.utils.instantiate(config['query_message_prompt_template'], _convert_="partial")
+
+        return kwargs
+
+    @classmethod
+    def instantiate_from_config(cls, config):
+        flow_config = deepcopy(config)
+
+        kwargs = {"flow_config": flow_config}
+
+        # ~~~ Set up prompts ~~~
+        kwargs.update(cls._set_up_prompts(flow_config))
+
+        # ~~~ Instantiate flow ~~~
+        return cls(**kwargs)
+
+    @staticmethod
+    def _get_message(prompt_template, input_data: Dict[str, Any]):
+        template_kwargs = {}
+        for input_variable in prompt_template.input_variables:
+            template_kwargs[input_variable] = input_data[input_variable]
+
+        msg_content = prompt_template.format(**template_kwargs)
+        return msg_content
+
+    def _read_input(self):
+        if not self.flow_config["request_multi_line_input_flag"]:
+            log.info("Please enter you single-line response and press enter.")
+            human_input = input()
+            return human_input
+
+        end_of_input_string = self.flow_config["end_of_input_string"]
+        log.info(f"Please enter your multi-line response below. "
+                 f"To submit the response, write `{end_of_input_string}` on a new line and press enter.")
+
+        content = []
+        while True:
+            line = input()
+            if line == self.flow_config["end_of_input_string"]:
+                break
+            content.append(line)
+        human_input = "\n".join(content)
+        return human_input
+
+    def run(self,
+            input_data: Dict[str, Any]) -> Dict[str, Any]:
+
+        query_message = self._get_message(self.query_message_prompt_template, input_data)
+        state_update_message = UpdateMessage_Generic(
+            created_by=self.flow_config['name'],
+            updated_flow=self.flow_config["name"],
+            data={"query_message": query_message},
+        )
+        self._log_message(state_update_message)
+
+        log.info(query_message)
+        human_input = self._read_input()
+
+        return {"human_input": human_input}

README.md

@@ -1,3 +1,24 @@
 ---
 license: mit
 ---
+## Description
+
+Reads input from the user's standard input.
+
+## Configuration parameters
+
+request_multi_line_input_flag (Boolean): If true, the user will be prompted to enter multiple lines of input. If false, the user will be prompted to enter a single line of input.
+
+query_message_prompt_template (Dict):
+    template (String): The template for the message to be presented to the user (e.g., "The last `{{action}}` completed successfully. Do you have any feedback that should be considered before selecting the next action?"). Default value is "".
+    input_variables (List): The list of variables to be used in the template (e.g., ["action"]). Default value is [].
+
+input_keys (List): The list of input keys that should be passed to the Flow as input. Default value is [].
+
+## Input interface
+
+By default, this Flow does not expect any input.
+
+## Output interface
+
+human_input (String): The user's input.

__init__.py

@@ -0,0 +1 @@
+from .HumanStandardInputFlow import HumanStandardInputFlow

pip_requirements.py

@@ -0,0 +1 @@
+# ToDo