We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 3921382 commit cde9682Copy full SHA for cde9682
1 file changed
src/eligibility_signposting_api/audit/audit_service.py
@@ -39,6 +39,9 @@ def audit(self, audit_record: dict) -> None:
39
"""
40
data = json.dumps(audit_record, default=str)
41
response_id = audit_record.get("response", {}).get("responseId")
42
+ if response_id is None:
43
+ response_id = str(uuid.uuid4())
44
+ logger.warning("Missing responseId in audit record; using UUID fallback")
45
partition_key = self.get_partition_key(str(response_id))
46
response = self.kinesis.put_record(
47
StreamName=self.audit_stream,
0 commit comments