Skip to content

Commit

Permalink
Add mart trigger
Browse files Browse the repository at this point in the history
  • Loading branch information
jrlegrand committed Feb 5, 2025
1 parent 8a8ab1c commit cd316cc
Showing 1 changed file with 1 addition and 1 deletion.
2 changes: 1 addition & 1 deletion airflow/dags/dailymed/dag.py
Original file line number Diff line number Diff line change
Expand Up @@ -143,7 +143,7 @@ def load():
@task
def transform():
subprocess = SubprocessHook()
result = subprocess.run_command(['dbt', 'run', '--select', 'models/staging/dailymed', 'models/intermediate/dailymed'], cwd='/dbt/sagerx')
result = subprocess.run_command(['dbt', 'run', '--select', 'models/staging/dailymed', 'models/intermediate/dailymed', 'ndcs_to_label_images'], cwd='/dbt/sagerx')
print("Result from dbt:", result)

extract() >> load() >> transform()
Expand Down

0 comments on commit cd316cc

Please sign in to comment.