if the status of the existing event is not IN_PROGRESS, we consider the ingested event as separate correction event and mark it as IN_PROGRESS
else we do an event sha check to check if event is a duplicate. If found duplicate we mark it as INGESTION_FAILED_DUPLICATE_EVENT else we process the existing event.
else
on idempotency check success, we mark event as IN_PROGRESS
else event is marked as INGESTION_FAILED_DUPLICATE_EVENT upon duplicate check
Upon processing an IN_PROGRESS event if the schema definition is not found
Upon processing an IN_PROGRESS event internal schema defined task like named_license, usage events, if the name of the internal schema is mentioned wrong
For undo event corrections, in case of existing event status not in (IN_PROGRESS, INGESTION_FAILED_DUPLICATE_EVENT, INGESTION_FAILED_INSUFFICIENT_CREDITS, REVERTED)
For redo event corrections, in case of existing event status not in (IN_PROGRESS, INGESTION_FAILED_DUPLICATE_EVENT, REVERTED, INGESTION_FAILED_UNITS_INVALID, INGESTION_FAILED_PAST_GRACE_PERIOD)
For redo_event event corrections, in case of existing event status not in (IN_PROGRESS, INGESTION_FAILED_DUPLICATE_EVENT, REVERTED, INGESTION_FAILED_UNITS_INVALID, INGESTION_FAILED_PAST_GRACE_PERIOD, INGESTION_FAILED_ACCOUNT_NOT_FOUND)
On processing an IN_PROGRESS event, if the event is not entitled and the schema has feature_details we try to deduct wallet entries, on failure of deduct wallet entries we mark it as INGESTION_FAILED_INSUFFICIENT_CREDITS
Assistant
Responses are generated using AI and may contain mistakes.