Writing a minimal TaskFlow Dag

Your team is starting a new data pipeline project. Before building the full pipeline, your lead asks you to set up a minimal Dag to verify the environment is working.

An exercise file includes dag.test() at the bottom, which runs the entire Dag in a single process so you can see task output directly.