Prompt [PARTICIPANT Error] error

[1130164523]

I would like to use the "contentfilteredtopic" feature. Here is my test code. Could you please tell me where I went wrong?
Here is the full error message:
2023-06-10 16:01:28.942 [DDSSQLFILTER Error] No TypeObject found for type HelloWorldtype -> Function eprosima::fastdds::dds::DDSSQLFilter::DDSFilterFactory::create_content_filter 2023-06-10 16:01:28.942 [PARTICIPANT Error] Could not create filter of class DDSSQL for expression "index > 5 -> Function eprosima::fastdds::dds::DomainParticipantImpl::create_contentfilteredtopic

Here is the full code:
`
import asyncio
import os
import argparse
import time
from ctypes import byref
from threading import Condition

if os.name == 'nt':
import win32api

win32api.LoadLibrary('HelloWorld')

import fastdds
import HelloWorld

class ReaderListener(fastdds.DataReaderListener):
def init(self, callback):
super().init()
self._callback = callback

def on_data_available(self, reader):
    info = fastdds.SampleInfo()
    data = HelloWorld.HelloWorld()
    reader.take_next_sample(data, info)
    self._callback.put_nowait(f"Received {data.message()} {data.index()}")

def on_subscription_matched(self, datareader, info):
    print(f"ReaderListener info.current_count_change {info.current_count_change}")
    if (0 < info.current_count_change):
        print("Subscribers matching Publishers {}\r\n".format(info.last_publication_handle))
    else:
        print("Publisher with mismatched subscribers {}\r\n".format(info.last_publication_handle))

class Reader():
def init(self, domain=0, callback=None):
factory = fastdds.DomainParticipantFactory.get_instance()
self.participant_qos = fastdds.DomainParticipantQos()
factory.get_default_participant_qos(self.participant_qos)
self.participant = factory.create_participant(domain, self.participant_qos)

    self.topic_data_type = HelloWorld.HelloWorldPubSubType()
    self.topic_data_type.setName("HelloWorldtype")
    self.type_support = fastdds.TypeSupport(self.topic_data_type)
    self.participant.register_type(self.type_support)


    self.topic_qos2 = fastdds.TopicQos()
    self.participant.get_default_topic_qos(self.topic_qos2)
    self.topic2 = self.participant.create_topic("HelloWorldTopic2", "HelloWorldtype", self.topic_qos2)


    self.filter_topic =self.participant.create_contentfilteredtopic("FilteredTopic", self.topic2,r"index > 5", [])

    self.subscriber_qos = fastdds. SubscriberQos()
    self.participant.get_default_subscriber_qos(self.subscriber_qos)
    self.subscriber = self.participant.create_subscriber(self.subscriber_qos)

    self.listener2 = ReaderListener(callback)
    self.reader_qos2 = fastdds.DataReaderQos()
    self.subscriber.get_default_datareader_qos(self.reader_qos2)
    self.reader = self.subscriber.create_datareader(self.filter_topic, self.reader_qos2, self.listener2)

def __del__(self):
    factory = fastdds.DomainParticipantFactory.get_instance()
    self.participant.delete_contained_entities()
    factory.delete_participant(self.participant)

import asyncio.queues

async def task_handler(_queue):

while True:
    try:

        eventobj = await _queue.get()
        print(eventobj)
        _queue.task_done()
    except Exception as e:
        print(e)

async def msg(info):
print(11)

if name == 'main':
async def main():
try:
_queue = asyncio.Queue()
bb = Reader(callback=_queue)
asyncio.create_task(task_handler(_queue))
while 1:
await asyncio.sleep(1)
except Exception as e:
print(e)

    del bb


asyncio.run(main())

`