2
공기 흐름 API에서 제공되는 SubDagOperator를 확장하려고 시도하면 공기 흐름 웹 서버 GUI에서이를 SubDagOperator로 인식하지 못하므로 하위 태그를 확대 할 수 없습니다.공기 흐름 : SubDagOperator를 확장하는 방법?
SubDagOperator를 서브 테이블로 확대하는 기능을 유지하면서 어떻게 확장 할 수 있습니까? 내가 놓친 게 있니?
A
답변
0
dag 자체로 서브 dag를 정의하는 경우이 방법이 효과적입니다.
공기 흐름의 좋은 예가 있습니다. 명명 규칙에도주의를 기울여야하며, 하위 태그 이름은 parent_name.child_name 형식이어야합니다.
주요 DAG
subdags https://github.com/apache/incubator-airflow/blob/master/airflow/example_dags/subdags/subdag.py
관련 문제
- 1. 공기 흐름 웹 서버
- 2. 공기 흐름 비단뱀 클라이언트
- 3. 공기 흐름 스케줄러를 데몬 프로세스로 실행하는 방법?
- 4. 공기 흐름 백필 작동하지 않음
- 5. 공기 흐름 DAG 향후 일정
- 6. 공기 흐름 실행 문제 DAG
- 7. 고 가용성을위한 공기 흐름 설정
- 8. 공기 흐름 <--> Greenplum
- 9. 공기 흐름 CI 설정 DAG
- 10. 공기 흐름 : 다음 작업으로 정보를 전달 (센서)
- 11. 공기 흐름 목록에서 깨진 DAG를 어떻게 삭제합니까? 공기 흐름 쇼 정보
- 12. 공기 흐름 : 실행 DAG 매 순간
- 13. 전체 DAG에 대한 공기 흐름 depends_on_past
- 14. 공기 흐름 백필 새 작업이 달그레에 추가
- 15. 공기 흐름 : PythonOperator : 'ds'인수를 포함해야하는 이유는 무엇입니까?
- 16. 공기 흐름 설치 성공적인,하지만 그것을
- 17. 환경 변수의 공기 흐름 구성이 작동하지 않습니다.
- 18. 공기 흐름 - 백필에서 성공한 작업을 어떻게 무시합니까?
- 19. 공기 흐름 - depends_on_past 및 trigger_rule이 동일합니까?
- 20. 명령 줄 공기 흐름 DAG 활성화 옵션
- 21. 공기 흐름 스케줄러를 데몬 프로세스로 실행하는 문제
- 22. 공기 흐름 - EMR 운영자의 작업 인스턴스
- 23. 공기 흐름 UI를 사용하여 전체 DAG 실행
- 24. 지속적으로 공기 흐름 DAG 실행을 예약하십시오.
- 25. Apache 공기 흐름 설치 후 오류
- 26. 공기 흐름 : 1.7 : GUI에서 DAG가 업데이트되지 않습니다.
- 27. Windows PyCharm의 공기 흐름 DAG 개발
- 28. TemplateNotFound 오류 실행 간단한 공기 흐름 BashOperator
- 29. for 루프에서 공기 흐름 작업 실행
- 30. 공기 흐름 웹 서버가 시작되지 않습니다
질문을 할 때마다. 지금까지 시도한 내용의 예를 추가하는 것이 가장 좋습니다. 문제가 발생할 수있는 부분을 사람들이 이해하도록 도와줍니다. – matt
아직 해결책이 없습니까? https://github.com/apache/incubator-airflow/blob/9d5cc6ef5fe18055395ab671d602d70ab18dcbd2/airflow/models.py#L3450의 코드를 보면,이 줄은 공기 흐름이 하위 코드를 결정하기 위해'SubDagOperator'를 사용함을 나타냅니다. 따라서 Airflow 코드를 변경하거나 새로운 버전이이를 지원하기를 기다리지 않는 한 SubDagOperator를 확장 할 수 없다고 생각합니다. – Freedom