BashOperator の実行順序を定義する

ビットシフト演算子について学んだところで、ワークフローに pull のステップとタスクの実行順序を組み込みましょう。現在、cleanup、consolidate、push_data の3つのコンポーネントが定義されています。

これまでどおり DAG analytics_dag が利用可能で、BashOperator はすでにインポート済みです。

pull_sales という名前の BashOperator を定義し、bash コマンドは wget https://salestracking/latestinfo?json にします。
pull_sales を cleanup タスクの前に実行されるように設定します。
ダウンストリームの演算子を使って、次に consolidate が実行されるように構成します。
最後に push_data が実行されるように、どちらかのビットシフト演算子を使って設定します。