diff --git a/dags/trial.py b/dags/trial.py
index 52eda4f..0ac7d93 100644
--- a/dags/trial.py
+++ b/dags/trial.py
@@ -2,7 +2,7 @@ from airflow import DAG
 from airflow.operators.python import PythonOperator
 from datetime import datetime
 
-from scripts.test_fao_load import run_fao_test
+from scripts.test_data import run_fao_test
 
 with DAG(
     dag_id="etl_fao_bigquery",