diff --git a/airflow/dags/rxnorm/dag.py b/airflow/dags/rxnorm/dag.py
index 7e4f7ed..1549bbe 100644
--- a/airflow/dags/rxnorm/dag.py
+++ b/airflow/dags/rxnorm/dag.py
@@ -41,6 +41,6 @@ def rxnorm():
 
     transform_task = transform(dag_id, models_subdir=['staging', 'intermediate'])
 
-    extract_task >> load >> transform()
+    extract_task >> load >> transform_task
 
 rxnorm()