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

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

    task_scraping = PythonOperator(
        task_id="run_pddikti_scraping",
        python_callable=run_scraping_logic # Memanggil fungsi eksternal
    )