Skip to content

Commit

Permalink
pass the check
Browse files Browse the repository at this point in the history
  • Loading branch information
Tian-2017 committed May 17, 2024
1 parent 41b3697 commit eda25bc
Showing 1 changed file with 1 addition and 10 deletions.
11 changes: 1 addition & 10 deletions scripts/jobs/rentsense_former_tenants_to_refined.py
Original file line number Diff line number Diff line change
Expand Up @@ -459,12 +459,6 @@
transformation_ctx="sow2b_dbo_ssminitransaction_source")
df10 = get_latest_partitions_optimized(df10)

# patch = glueContext.create_data_frame.from_catalog(
# database=source_raw_database,
# table_name="property_rent_patches",
# transformation_ctx="property_rent_patches_source")
# patch = get_latest_partitions_optimized(patch)

patch_officer = glueContext.create_data_frame.from_catalog(
database=source_raw_database,
table_name="rent_officer_patch_mapping",
Expand Down Expand Up @@ -529,7 +523,7 @@

bals_filter = balance.withColumn("BalanceDate", F.to_date(F.col("import_date"), "yyyyMMdd")) \
.withColumn("paymentreference2", F.trim(F.col("RentAccount"))) \
.filter(col("previousweekbalance") != 0.00) \
.filter(col("previousweekbalance") != 0) \
.withColumnRenamed("import_date", "bal_date")

accounts2 = accounts.join(bals_filter, accounts.paymentreference == bals_filter.paymentreference2, "right")
Expand Down Expand Up @@ -590,9 +584,6 @@
accounts10 = add_import_time_columns(accounts9)

# create the accounts table referenced in the other extracts

# accounts = accounts3

dynamic_frame = DynamicFrame.fromDF(accounts10.repartition(1), glueContext, "target_data_to_write")

# save out the data
Expand Down

0 comments on commit eda25bc

Please sign in to comment.