remove accidental redefinition of variable. add extra information to log

This commit is contained in:
Daniel Roth 2026-02-26 14:27:52 +00:00
parent 432f050e69
commit b7f7c40552

View file

@ -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)}"
)