Upload 3 files

DoNothingAtomicFlow.py

@@ -0,0 +1,26 @@
+import traceback
+from copy import deepcopy
+from typing import Dict, Any
+
+from flows.base_flows import AtomicFlow
+
+
+class DoNothingAtomicFlow(AtomicFlow):
+    def __init__(self,
+                 **kwargs):
+        super().__init__(**kwargs)
+
+    @classmethod
+    def instantiate_from_config(cls, config):
+        flow_config = deepcopy(config)
+
+        kwargs = {"flow_config": flow_config}
+
+        # ~~~ Instantiate flow ~~~
+        return cls(**kwargs)
+
+    def run(
+            self,
+            input_data: Dict[str, Any]):
+        response = input_data.copy()
+        return {"donothing_output": response}

DoNothingAtomicFlow.yaml

@@ -0,0 +1,3 @@
+name: "DoNothingAtomicFlow"
+description: "A flow that returns exactly the input data"
+

__init__.py

@@ -0,0 +1 @@
+from DoNothingAtomicFlow import DoNothingAtomicFlow