Skip to content

Latest commit

 

History

History
 
 

dags

Folders and files

NameName
Last commit message
Last commit date

parent directory

..
subdir1
subdir1
 
 
subdir2
subdir2
 
 
.airflowignore
.airflowignore
 
 
.gitignore
.gitignore
 
 
README.md
README.md
 
 
no_dags.py
no_dags.py
 
 
test_backfill_pooled_tasks.py
test_backfill_pooled_tasks.py
 
 
test_clear_subdag.py
test_clear_subdag.py
 
 
test_cli_triggered_dags.py
test_cli_triggered_dags.py
 
 
test_dag_with_no_tags.py
test_dag_with_no_tags.py
 
 
test_default_impersonation.py
test_default_impersonation.py
 
 
test_default_views.py
test_default_views.py
 
 
test_double_trigger.py
test_double_trigger.py
 
 
test_example_bash_operator.py
test_example_bash_operator.py
 
 
test_heartbeat_failed_fast.py
test_heartbeat_failed_fast.py
 
 
test_impersonation.py
test_impersonation.py
 
 
test_impersonation_subdag.py
test_impersonation_subdag.py
 
 
test_invalid_cron.py
test_invalid_cron.py
 
 
test_issue_1225.py
test_issue_1225.py
 
 
test_latest_runs.py
test_latest_runs.py
 
 
test_logging_in_dag.py
test_logging_in_dag.py
 
 
test_mark_success.py
test_mark_success.py
 
 
test_miscellaneous.py
test_miscellaneous.py
 
 
test_missing_owner.py
test_missing_owner.py
 
 
test_multiple_dags.py
test_multiple_dags.py
 
 
test_no_impersonation.py
test_no_impersonation.py
 
 
test_on_failure_callback.py
test_on_failure_callback.py
 
 
test_on_kill.py
test_on_kill.py
 
 
test_only_dummy_tasks.py
test_only_dummy_tasks.py
 
 
test_prev_dagrun_dep.py
test_prev_dagrun_dep.py
 
 
test_retry_handling_job.py
test_retry_handling_job.py
 
 
test_scheduler_dags.py
test_scheduler_dags.py
 
 
test_subdag.py
test_subdag.py
 
 
test_task_view_type_check.py
test_task_view_type_check.py
 
 
test_with_non_default_owner.py
test_with_non_default_owner.py
 
 
test_zip.zip
test_zip.zip
 
 
test_zip_invalid_cron.zip
test_zip_invalid_cron.zip
 
 

README.md

Unit Tests DAGs Folder

This folder contains DAGs for Airflow unit testing.

To access a DAG in this folder, use the following code inside a unit test. Note this only works when test_mode is on; otherwise the normal Airflow DAGS_FOLDER will take precedence.

dagbag = DagBag()
dag = dagbag.get_dag(dag_id)