Skip to content

Instantly share code, notes, and snippets.

View allansene's full-sized avatar

Allan Sene Oliveira allansene

View GitHub Profile
@allansene
allansene / dag.py
Created September 12, 2019 00:22 — forked from adamhaney/dag.py
DBT Airflow DAG with model/graph introspection
from datetime import datetime, timedelta
import networkx as nx
from airflow import DAG
from airflow.operators import BashOperator, SubDagOperator
start_date = datetime(year=2017, month=6, day=13, hour=19, minute=0)
schedule_interval = '0 * * * 1-5'
default_args = {