Chuyển một Dag kiểu cũ sang TaskFlow

Đội của bạn đã quyết định áp dụng TaskFlow API cho tất cả pipeline mới. Quản lý yêu cầu bạn viết lại một pipeline ETL hiện có đang dùng PythonOperator với cách nối thủ công bằng >>.

Phiên bản cổ điển gốc có sẵn để tham khảo tại dags/classic_etl.py. Một bản TaskFlow đã được dựng sẵn đang chờ bạn hoàn thiện.