Skip to content

Commit d39b769

Browse files
committed
Change import_datetime to import_date to account for changes to the new source data tables
1 parent 459b81e commit d39b769

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

scripts/jobs/data_and_insight/person_matching_module.py

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -276,7 +276,7 @@ def prepare_clean_housing_data(person_reshape: DataFrame, assets_reshape: DataFr
276276
A prepared and cleaned dataframe containing housing tenancy data.
277277
"""
278278
tenure_reshape = tenure_reshape.filter((tenure_reshape["endoftenuredate"].isNull()) | (
279-
tenure_reshape["endoftenuredate"].cast(DateType()) > current_date()))
279+
tenure_reshape["endoftenuredate"].cast(DateType()) > current_date()))
280280

281281
assets_reshape = assets_reshape.filter(assets_reshape['assettype'] == 'Dwelling')
282282

@@ -865,7 +865,7 @@ def prepare_clean_freedom_pass_admissions_data(freedom_df: DataFrame) -> DataFra
865865
.withColumnRenamed("district", "address_line_4") \
866866
.withColumnRenamed("postcode", "post_code") \
867867
.withColumnRenamed("email_address", "email") \
868-
.withColumn("date_of_birth", to_date(col("date_of_birth"), format="dd/MM/yyyy"))\
868+
.withColumn("date_of_birth", to_date(col("date_of_birth"), format="dd/MM/yyyy")) \
869869
.withColumn("uprn", lit("")) \
870870
.withColumn("source_filter", lit("freedom_passes_2024")) \
871871
.select(col("source"), col("source_id"), col("title"), col("first_name"), col("middle_name"),

0 commit comments

Comments
 (0)