Google Git
Sign in
apache / airflow / c7c680ee3b5a6f61012c222f092cd8c19f7e1b3d / . / tests / dags
tree: 874f3fed98b4d2ba9a2428047db47cb20a2367bb [path history] [tgz]
  1. subdir1/
  2. subdir2/
  3. .airflowignore
  4. .airflowignore_glob
  5. .gitignore
  6. __init__.py
  7. no_dags.py
  8. README.md
  9. test_backfill_with_upstream_failed_task.py
  10. test_clear_subdag.py
  11. test_cli_triggered_dags.py
  12. test_dag_parsing_context.py
  13. test_dag_warnings.py
  14. test_dag_warnings.zip
  15. test_dag_with_no_tags.py
  16. test_dag_xcom_openlineage.py
  17. test_dagrun_fast_follow.py
  18. test_dags_folder.py
  19. test_datasets.py
  20. test_default_impersonation.py
  21. test_default_views.py
  22. test_double_trigger.py
  23. test_example_bash_operator.py
  24. test_external_task_sensor_check_existense.py
  25. test_failing.py
  26. test_heartbeat_failed_fast.py
  27. test_impersonation.py
  28. test_impersonation_subdag.py
  29. test_imports.py
  30. test_invalid_cron.py
  31. test_invalid_dup_task.py
  32. test_invalid_param.py
  33. test_invalid_param2.py
  34. test_invalid_param3.py
  35. test_invalid_param4.py
  36. test_issue_1225.py
  37. test_latest_runs.py
  38. test_logging_in_dag.py
  39. test_mapped_classic.py
  40. test_mapped_taskflow.py
  41. test_mark_state.py
  42. test_miscellaneous.py
  43. test_missing_owner.py
  44. test_multiple_dags.py
  45. test_no_impersonation.py
  46. test_on_failure_callback.py
  47. test_on_kill.py
  48. test_only_empty_tasks.py
  49. test_parsing_context.py
  50. test_prev_dagrun_dep.py
  51. test_retry_handling_job.py
  52. test_scheduler_dags.py
  53. test_sensor.py
  54. test_subdag.py
  55. test_task_view_type_check.py
  56. test_valid_param.py
  57. test_valid_param2.py
  58. test_with_non_default_owner.py
  59. test_workday_timetable.py
  60. test_zip.zip
tests/dags/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)