Skip to content

Commit 471d736

Browse files
committed
replaces incorrect column in extract script
1 parent d19ef0f commit 471d736

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

model/data/databricks.py

+2-2
Original file line numberDiff line numberDiff line change
@@ -138,9 +138,9 @@ def get_hsa_activity_table(self) -> pd.DataFrame:
138138
"""
139139
return (
140140
self._spark.read.table("hsa_activity_tables")
141-
.filter(F.col("provider") == self._dataset)
141+
.filter(F.col("dataset") == self._dataset)
142142
.filter(F.col("fyear") == self._fyear)
143-
.drop("provider", "fyear")
143+
.drop("dataset", "fyear")
144144
.toPandas()
145145
)
146146

0 commit comments

Comments
 (0)