airflow-dbt-python/examples/basic_dag.py at master · OmnipresentGroup/airflow-dbt-python · GitHub

This repository was archived by the owner on Jan 9, 2023. It is now read-only.

24 lines (22 loc) · 686 Bytes

"""Sample basic DAG which dbt runs a project."""

import datetime as dt

from airflow import DAG

from airflow.utils.dates import days_ago

from airflow_dbt_python.dbt.operators import DbtRunOperator

with DAG(

dag_id="example_basic_dbt_run",

schedule_interval="0 * * * *",

start_date=days_ago(1),

catchup=False,

dagrun_timeout=dt.timedelta(minutes=60),

) as dag:

dbt_run = DbtRunOperator(

task_id="dbt_run_hourly",

project_dir="/path/to/my/dbt/project/",

profiles_dir="~/.dbt/",

select=["+tag:hourly"],

exclude=["tag:deprecated"],

target="production",

profile="my-project",

full_refresh=False,

)

Expand file tree