log date of duplicate records removed

jacob-a-brown · jacob-a-brown · commit 93880d9100fc · 2025-05-21T12:52:39.000-06:00
diff --git a/backend/connectors/wqp/source.py b/backend/connectors/wqp/source.py
@@ -164,8 +164,9 @@ def _clean_records(self, records):
                         raise ValueError(
                             f"Multiple TDS records found for {site_id} with ActivityIdentifier {activity_identifier} but no 70300, 70301, or 70303 pcodes found."
                         )
+                    record_date = kept_record["ActivityStartDate"]
                     self.log(
-                        f"Removing duplicates for {site_id} with ActivityIdentifier {activity_identifier}. Keeping record with pcode {pcode}."
+                        f"Removing duplicates for {site_id} on {record_date} with ActivityIdentifier {activity_identifier}. Keeping record with pcode {pcode}."
                     )
                 else:
                     kept_record = list(ai_records.values())[0]

Original file line number	Diff line number	Diff line change
`@@ -164,8 +164,9 @@ def _clean_records(self, records):`
`164`	`164`	`raise ValueError(`
`165`	`165`	`f"Multiple TDS records found for {site_id} with ActivityIdentifier {activity_identifier} but no 70300, 70301, or 70303 pcodes found."`
`166`	`166`	`)`
	`167`	`+ record_date = kept_record["ActivityStartDate"]`
`167`	`168`	`self.log(`
`168`		`- f"Removing duplicates for {site_id} with ActivityIdentifier {activity_identifier}. Keeping record with pcode {pcode}."`
	`169`	`+ f"Removing duplicates for {site_id} on {record_date} with ActivityIdentifier {activity_identifier}. Keeping record with pcode {pcode}."`
`169`	`170`	`)`
`170`	`171`	`else:`
`171`	`172`	`kept_record = list(ai_records.values())[0]`