diff --git a/apps/cic-ussd/cic_ussd/tasks/processor.py b/apps/cic-ussd/cic_ussd/tasks/processor.py index 7796ad12..9916d4d5 100644 --- a/apps/cic-ussd/cic_ussd/tasks/processor.py +++ b/apps/cic-ussd/cic_ussd/tasks/processor.py @@ -47,7 +47,8 @@ def cache_statement(parsed_transaction: dict, querying_party: str): statement_transactions = [] if cached_statement: statement_transactions = json.loads(cached_statement) - statement_transactions.append(parsed_transaction) + if parsed_transaction not in statement_transactions: + statement_transactions.append(parsed_transaction) data = json.dumps(statement_transactions) identifier = bytes.fromhex(querying_party) key = cache_data_key(identifier, MetadataPointer.STATEMENT)