Skip to content

Commit

Permalink
Create suburban_junctions (#50)
Browse files Browse the repository at this point in the history
  • Loading branch information
atalyaalon authored Feb 14, 2024
1 parent eabcbb1 commit dcdd02f
Showing 1 changed file with 20 additions and 0 deletions.
20 changes: 20 additions & 0 deletions airflow_server/dags/suburban_junctions
Original file line number Diff line number Diff line change
@@ -0,0 +1,20 @@
from airflow import DAG
from airflow.utils.dates import days_ago

from anyway_etl_airflow.operators.cli_bash_operator import CliBashOperator


dag_kwargs = dict(
default_args={
'owner': 'airflow',
},
schedule_interval=None,
catchup=False,
start_date=days_ago(1),
)


with DAG('load-suburban-junctions', **dag_kwargs) as load_suburban_junctions:
CliBashOperator(cmd='anyway-etl anyway-kubectl-exec python3 main.py process suburban-junctions',
task_id='load-suburban-junctions'
)

0 comments on commit dcdd02f

Please sign in to comment.