명령어
airflow tasks test [Dag ID] [Task ID] [Start Date] |
예)
위와 같은 DAG 가 있다고 하자.
task_id 가 "is_forex_rates_available" 인 task 를 테스트하려면
아래 명령어를 사용하면 된다.
airflow tasks test forex_data_pipeline is_forex_rates_available 2022-06-01 |
'Airflow' 카테고리의 다른 글
| [Airflow] DAG-level permissions 주는 방법 (1) | 2022.07.27 |
|---|---|
| [Airflow] LocalExecutor + postgreSQL 연동하기 (0) | 2022.07.20 |
| [Airflow] 기술 질문 대비 적어두는 것들 (0) | 2022.07.20 |
| [Airflow] execution_date 와 schedule_interval 에 대한 설명 링크 (0) | 2022.06.21 |
| [Airflow] parallelism, max_active_runs_per_dag, max_active_tasks_per_dag 이해하기 (2) | 2022.05.07 |