Merge pull request #357 from coderxio/rxnorm-transform-typo

Fix typo in RxNorm transform
coderxio · Jan 23, 2025 · b814958 · b814958
2 parents a2aa1a0 + 83111c3
commit b814958
Showing 1 changed file with 1 addition and 1 deletion.
diff --git 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()