Skip to content

Commit

Permalink
WIP
Browse files Browse the repository at this point in the history
  • Loading branch information
jecos committed Mar 8, 2024
1 parent 6a7d700 commit e43e29d
Show file tree
Hide file tree
Showing 3 changed files with 3 additions and 3 deletions.
2 changes: 1 addition & 1 deletion dags/etl_index.py
Original file line number Diff line number Diff line change
Expand Up @@ -10,7 +10,7 @@ def index_operator(name:str):
name=f'etl-index-{name}-centric'
)
with DAG(
dag_id='index_task',
dag_id='etl-index',
start_date=datetime(2022, 1, 1),
schedule_interval=None,
params={
Expand Down
2 changes: 1 addition & 1 deletion dags/etl_prepare_index.py
Original file line number Diff line number Diff line change
Expand Up @@ -16,7 +16,7 @@ def prepare_index():
name='etl-prepare-index'
)
with DAG(
dag_id='prepare_index',
dag_id='etl-prepare-index',
start_date=datetime(2022, 1, 1),
schedule_interval=None,
params={
Expand Down
2 changes: 1 addition & 1 deletion dags/etl_snv_enrich.py
Original file line number Diff line number Diff line change
Expand Up @@ -5,7 +5,7 @@
from lib.operators.spark import SparkOperator

with DAG(
dag_id='etl_snv_enrich',
dag_id='etl-snv-enrich',
start_date=datetime(2022, 1, 1),
schedule_interval=None,
params={
Expand Down

0 comments on commit e43e29d

Please sign in to comment.