เพิ่มขั้นตอนการอนุมัติจากมนุษย์

# Import ApprovalOperator
from airflow.providers.standard.operators.____ import ____

@dag(start_date=datetime(2026,4,15))
def data_warehouse_dag():  
  # Create the approve_gate approval task
  approve_gate = ____(
        task_id="approve_sales_data",
        # Set the title for the approval request shown to the reviewer
        ____="Sales data processing - Approval Required",
        body=(
            "Please review the sales data produced by the *pull_raw_data* task."
            "Approve to push leads to the data warehouse, or Reject to halt the run."
        ),
    )
  
  pull_raw_data() >> approve_gate >> push_to_warehouse()
data_warehouse_dag()