最小構成の TaskFlow Dag を作成する

あなたのチームは、新しいデータパイプラインプロジェクトを開始しようとしています。本格的なパイプラインを構築する前に、リーダーから環境が正しく動作しているか確認するための最小構成の Dag をセットアップするよう依頼されました。

演習ファイルの末尾には dag.test() が含まれており、Dag 全体を単一プロセスで実行してタスクの出力を直接確認できます。