지구정복

airflow 3버전 이상부터 사용할 수 있는 기능 아래와 같이 두 개의 dag가 있다.a dag: task11 -> task12b dag: task21 -> task22 이때 a dag가 끝나자마자 b dag를 실행시키고 싶을 경우a dag의 최종 결과물(특정 디렉터리에 파일 생성)이 생성되면 b dag가 트리거되도록 실행하는 기능이다. 아래는 예제 코드from airflow.sdk import asset# 1️⃣ First asset DAG@asset( schedule="@daily", # runs every day)def first_asset(): """ This asset returns some data. This return value is stored..