diff --git a/backend/app/plan/router.py b/backend/app/plan/router.py index 08138ff1..6c691cc1 100644 --- a/backend/app/plan/router.py +++ b/backend/app/plan/router.py @@ -88,9 +88,6 @@ async def trigger_categorisation( if not batch_property_ids: continue - batch_property_ids: List[int] = [ - pid for pid in property_ids if pid % num_property_batches == batch_index - ] batch_request: CategorisationTriggerRequest = CategorisationTriggerRequest( portfolio_id=payload.portfolio_id, scenarios_to_consider=payload.scenarios_to_consider, @@ -110,7 +107,7 @@ async def trigger_categorisation( ) logger.info( - f"Chunk {batch_index} sent to SQS. Property IDs {min(batch_property_ids)}–{max(batch_property_ids)}. Message ID: {response.get('MessageId')}" + f"Chunk {batch_index} sent to SQS. {len(batch_property_ids)} Property IDs in batch (total {len(property_ids)}). Property IDs {min(batch_property_ids)}–{max(batch_property_ids)}. Message ID: {response.get('MessageId')}" # f"Chunk {batch_index} sent to SQS. Property IDs {min(batch_property_ids)}–{max(batch_property_ids)}" )