diff --git a/templates/sqs/handler.py b/templates/sqs/handler.py index 1bff9b4..990e543 100644 --- a/templates/sqs/handler.py +++ b/templates/sqs/handler.py @@ -43,7 +43,7 @@ def handle_record(self, record: SQSRecord) -> None: try: message = SqsMessage.model_validate_json(record.body) processed = ProcessedItem(id=message.id, content=message.content, status="PROCESSED") - self._repository.put_item(processed.model_dump()) + self._repository.put_item(processed.dump()) logger.info("Successfully processed and stored message", extra={"messageId": message.id}) except Exception as exc: logger.error("Failed to process SQS record", exc_info=exc)