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
 
 
.airflowignore_glob
.airflowignore_glob
 
 
.gitignore
.gitignore
 
 
README.md
README.md
 
 
__init__.py
__init__.py
 
 
no_dags.py
no_dags.py
 
 
test_backfill_with_upstream_failed_task.py
test_backfill_with_upstream_failed_task.py
 
 
test_clear_subdag.py
test_clear_subdag.py
 
 
test_cli_triggered_dags.py
test_cli_triggered_dags.py
 
 
test_dag_parsing_context.py
test_dag_parsing_context.py
 
 
test_dag_warnings.py
test_dag_warnings.py
 
 
test_dag_warnings.zip
test_dag_warnings.zip
 
 
test_dag_with_no_tags.py
test_dag_with_no_tags.py
 
 
test_dag_xcom_openlineage.py
test_dag_xcom_openlineage.py
 
 
test_dagrun_fast_follow.py
test_dagrun_fast_follow.py
 
 
test_dags_folder.py
test_dags_folder.py
 
 
test_datasets.py
test_datasets.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_external_task_sensor_check_existense.py
test_external_task_sensor_check_existense.py
 
 
test_failing.py
test_failing.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_imports.py
test_imports.py
 
 
test_invalid_cron.py
test_invalid_cron.py
 
 
test_invalid_dup_task.py
test_invalid_dup_task.py
 
 
test_invalid_param.py
test_invalid_param.py
 
 
test_invalid_param2.py
test_invalid_param2.py
 
 
test_invalid_param3.py
test_invalid_param3.py
 
 
test_invalid_param4.py
test_invalid_param4.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_mapped_classic.py
test_mapped_classic.py
 
 
test_mapped_taskflow.py
test_mapped_taskflow.py
 
 
test_mark_state.py
test_mark_state.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_empty_tasks.py
test_only_empty_tasks.py
 
 
test_openlineage_execution.py
test_openlineage_execution.py
 
 
test_parsing_context.py
test_parsing_context.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_sensor.py
test_sensor.py
 
 
test_subdag.py
test_subdag.py
 
 
test_task_view_type_check.py
test_task_view_type_check.py
 
 
test_valid_param.py
test_valid_param.py
 
 
test_valid_param2.py
test_valid_param2.py
 
 
test_with_non_default_owner.py
test_with_non_default_owner.py
 
 
test_workday_timetable.py
test_workday_timetable.py
 
 
test_zip.zip
test_zip.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)