from airflow import DAG
from pendulum import datetime

from common.dbt_tasks import DbtOperator

with DAG(
        dag_id='dbt',
        schedule_interval='@daily',
        default_args=dict(
            owner='egor'
        ),
        start_date=datetime(2022, 12, 1),
        catchup=False,
) as dag:
    dbt_run = DbtOperator(
        task_id='dbt_run',
        project='dbt1',
        command='run',
    )