さらに @tasks を使う

ワークフローの実装を続けるために、ダウンロードしたファイルの変更内容を解析・保存するステップを追加します。DAG process_sales はすでに定義されており、pull_file タスクも追加済みです。今回は、Python 関数 parse_file(inputfile, outputfile) があらかじめ定義されています。

Airflow のタスクを実装する際、個々のステップの内容を完全に理解していなくても問題ありません。各ステップを Airflow の構造の中に正しく組み込む方法を理解していれば、目的のワークフローを実装できます。