Skip to content

Commit 099aace

Browse files
authored
Merge pull request #495 from The-Strategy-Unit/fix-inequalities-databricks-bug
fix bug in inequalities for PBM notebook
2 parents 4893921 + 17cc419 commit 099aace

File tree

1 file changed

+4
-2
lines changed

1 file changed

+4
-2
lines changed

src/nhp/model/data/databricks.py

Lines changed: 4 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -341,6 +341,8 @@ def get_inequalities(self) -> pd.DataFrame:
341341
:return: the inequalities dataframe
342342
:rtype: pd.DataFrame
343343
"""
344-
return self._spark.read.table("nhp.default.inequalities").filter(
345-
F.col("fyear") == self._year * 100 + (self._year + 1) % 100
344+
return (
345+
self._spark.read.table("nhp.default.inequalities")
346+
.filter(F.col("fyear") == self._year * 100 + (self._year + 1) % 100)
347+
.toPandas()
346348
)

0 commit comments

Comments
 (0)