Pick the most simple example, e.g., the data corruption analysis, and implement it without any optimizations, just execute the generated planes directly with the DagExecutor
Add a new artificial DAG node type that can be used to "extract" (named) pipeline intermediate results to outside the pipeline. Basically, something that can capture the results from operations like aggregate, that we want to store after a pipeline run in some DAG execution result map.
Description