from airflow import DAG
from airflow.operators.python import PythonOperator
from datetime import datetime

from scripts.test_data import run_fao_test

with DAG(
    dag_id="etl_fao_bigquery",
    start_date=datetime(2026, 3, 3),
    schedule_interval="@daily",
    catchup=False
) as dag:

    task_load_fao = PythonOperator(
        task_id="load_fao_to_bigquery",
        python_callable=run_fao_test
    )