@task 더 활용하기

워크플로우 구현을 이어가려면, 다운로드한 파일의 변경 사항을 파싱하고 저장하는 단계를 추가해야 합니다. DAG process_sales는 이미 정의되어 있으며, pull_file 태스크도 추가된 상태입니다. 이번 실습에서는 Python 함수 parse_file(inputfile, outputfile)이 미리 정의되어 있습니다.

Airflow 태스크를 구현할 때, 각 단계의 세부 내용을 반드시 이해하지 않아도 괜찮습니다. Airflow 구조 안에서 각 단계를 올바르게 감싸는 방법만 알고 있다면, 원하는 워크플로우를 구현할 수 있습니다.