![]() ![]() Note that if you use depends_on_past=True, individual task instances airflow webserver will start a web server if youĪre interested in tracking the progress visually as your backfill progresses. If you do have a webserver up, you will be able From datetime import datetime, timedelta from textwrap import dedent # The DAG object we'll need this to instantiate a DAG from airflow import DAG # Operators we need this to operate! from import BashOperator # These args will get passed on to each operator # You can override them on a per-task basis during operator initialization default_args =, ) t1 > Įverything looks like it’s running fine so let’s run a backfill.īackfill will respect your dependencies, emit logs into files and talk to
0 Comments
Leave a Reply. |
AuthorWrite something about yourself. No need to be fancy, just an overview. ArchivesCategories |