query the GSI

nhsdevws · nhsdevws · commit e46b182c106b · 2025-08-01T13:02:31.000+01:00
diff --git a/lambdas/id_sync/src/ieds_db_operations.py b/lambdas/id_sync/src/ieds_db_operations.py
@@ -152,6 +152,7 @@ def get_items_to_update(old_patient_pk: str) -> list:
     logger.info(f"Getting items to update for old patient PK: {old_patient_pk}")
     try:
         response = get_ieds_table().query(
+            IndexName='PatientGSI',  # query the GSI
             KeyConditionExpression=Key('PatientPK').eq(old_patient_pk),
             Limit=BATCH_SIZE
         )

Original file line number	Diff line number	Diff line change
`@@ -152,6 +152,7 @@ def get_items_to_update(old_patient_pk: str) -> list:`
`152`	`152`	`logger.info(f"Getting items to update for old patient PK: {old_patient_pk}")`
`153`	`153`	`try:`
`154`	`154`	`response = get_ieds_table().query(`
	`155`	`+ IndexName='PatientGSI', # query the GSI`
`155`	`156`	`KeyConditionExpression=Key('PatientPK').eq(old_patient_pk),`
`156`	`157`	`Limit=BATCH_SIZE`
`157`	`158`	`)`