How to render an Airflow template for testing
Do you know what I do when I have to test a failing Airflow task? I copy the rendered template and run the code on my own, without Airflow. It is way easier to fiddle with the parameters, for example, to get more verbose output.
To get a rendered template, I used to open an instance of the task, copy the code, and change the parameters to match the execution date I wanted. That is the long and error-prone way to do it.
It turns out that the Airflow command-line interface has a command that generates a rendered template of a given task for the execution date we choose. No more copy-pasting and looking for parameters to change!
All we need is this command:
1 airflow render dag_id task_id execution_date
Parsing machine learning logs with Ahana, a managed Presto service, and Cube, a headless BI solution
Check out my article published on the Cube.dev blog!
You may also like
- Run a command on a remote server using SSH in Airflow
- How to run PySpark code using the Airflow SSHOperator
- Pass parameters to SQL query when using PostgresOperator in Airflow
- Use LatestOnlyOperator to skip some tasks while running a backfill in Airflow
- How to use Airflow backfill to run DAGs for a specified date in the past?
- Data/MLOps engineer by day
- DevRel/copywriter by night
- Python and data engineering trainer
- Conference speaker
- Contributed a chapter to the book "97 Things Every Data Engineer Should Know"
- Twitter: @mikulskibartosz