|
df_treatments = ( |
|
spark.read.table(table_names.hes_aae_treatments) |
|
.filter(F.col("treatment") != "24") |
|
.select("aekey", "fyear", "procode3") |
|
) |
|
|
|
df_investigations = ( |
|
spark.read.table(table_names.hes_aae_investigations) |
|
.filter(~F.col("investigation").isin(["22", "99"])) |
|
.select("aekey", "fyear", "procode3") |
|
) |
| Code |
Treatment |
Investigation |
| 22 |
Guidance/advice only |
Dental investigation |
| 24 |
Tetanus |
None |
| 99 |
None |
Other |
should be
df_treatments = (
spark.read.table(table_names.hes_aae_treatments)
.filter(~F.col("treatment").isin(["22", "99"])
.select("aekey", "fyear", "procode3")
)
df_investigations = (
spark.read.table(table_names.hes_aae_investigations)
.filter(F.col("investigation") != "24")
.select("aekey", "fyear", "procode3")
)
nhp_data/src/nhp/data/raw_data/aae.py
Lines 64 to 74 in cff9dde
should be