context.cs

public async Task<int> SaveChangesAsync(Guid messageId)
{
    using (var transaction = Database.BeginTransaction())
    {
        var result = await SaveChangesAsync();
        
        IdempotentIds.Add(new Idempotent { IdempotentId = messageId });

        try
        {
            await SaveChangesAsync();
        }
        catch (DbUpdateException ex)
        {
            // Duplicate Key Error Number
            if (ex.InnerException?.InnerException != null && (ex.InnerException.InnerException as MySqlException)?.Number == 1062) return 0;
            throw;
        }

        transaction.Commit();

        return result;
    }
}