globe

Live with Astronomer

How to easily test your Airflow DAGs with the new dag.test() function

Watch On Demand

Hosted By

  • Kenten Danas Kenten Danas Lead Developer Advocate
    Astronomer
  • Tamara Fingerlin Tamara Fingerlin Developer Advocate
    Astronomer

This “Live with Astronomer” session covers how to use the new dag.test() function to quickly test and debug your Airflow DAGs directly in your IDE. Using the dag.test() function speeds up iterative development by running tasks in a single, serialized Python process that does not require running Airflow.

Questions covered in this session include:

  • How does the dag.test() function work and what version of Airflow do I need to use it?
  • What are the prerequisites for the environment I run dag.test() in?
  • Which operators does dag.test() work best with?
  • How can I test argument-specific DAG runs with dag.test()?

Learn more about testing and debugging DAGs in this guide and in the official Airflow documentation. All code shown during this event can be found in this repo.



Astronomer Apache Airflow Fundamentals Certification badge

Get Apache Airflow Certified

If you want to learn more about how to get started with Airflow, you can join the thousands of other data engineers who have received the Astronomer Certification for Apache Airflow Fundamentals. This exam assesses an understanding of the basics of the Airflow architecture and the ability to create simple data pipelines for scheduling and monitoring tasks.

Learn More About Certification