diff --git a/dags/main_pipeline.py b/dags/main_pipeline.py
index 4c883b3..025fb3c 100644
--- a/dags/main_pipeline.py
+++ b/dags/main_pipeline.py
@@ -2,7 +2,7 @@ from airflow import DAG
 from airflow.operators.python import PythonOperator
 from datetime import datetime
 # Import fungsi dari folder scripts
-from scripts.scraper_pddikti import run_scraping_logic
+from scripts.scraper_pddikti import run_sync_logic
 
 with DAG(
     dag_id="sync_dosen_spota_to_directus",
@@ -13,5 +13,5 @@ with DAG(
 
     task_scraping = PythonOperator(
         task_id="run_pddikti_scraping",
-        python_callable=run_scraping_logic # Memanggil fungsi eksternal
+        python_callable=run_sync_logic # Memanggil fungsi eksternal
     )
\ No newline at end of file