DAG에 인수를 전달하고, 태스크 아파치 에어 플로우

Question

나는 apache airflow 1.8을 탐색 중입니다. 나는 DAGs 또는 tasks에 인수를 전달할 수있는 방법이 있습니까? 아니면 backfilling입니까? 여기

은 같은 것입니다 내가

airflow backfill My_DAG -s some_date -e end_date argument_for_t1 argument_for_t2 

, 찾고 있어요하거나 인수의 array 될 수 있다고.

인자를 전달할 방법이 있습니까? 나는 많은 것을 수색했지만 아무 것도 찾을 수 없었다.

Answer 1

을 채우기 그때 나는 내가 airflow variables -s my_var="some value"

를 사용하여 변수를 설정할 수있는 솔루션을 가로 질러왔다

이제 애플리케이션 전체에서 my_var에 액세스 할 수 있습니다. 더 많은 옵션에 대한

은 한 번에 하나의 실행하는 데 문제가있는 경우이 허용됩니다 cli

Answer 2

Backfill은 실패한/놓친/잘못 구성된 DAG를 다시 실행하기 때문에 명령 줄 인수를 제공 할 수있는 조항이 없습니다.

그러나 DagBag 폴더로 이동하여 DAG 개체에 PARAMS을 제공 할 수 있습니다 (변경/기존 DAG를 수정)를 DAG