Redisearch returning empty result

[shoang22]

Hello,

I'm trying to add documents to redis and query them with Redisearch:

async def test_redis(db: redis.Redis):
    source_name = "my_source"
    schema = (
        TextField("type"),
        TextField("page"),
        TextField("text"),
    )
    await db.ft(source_name).create_index(
        schema, 
        definition=IndexDefinition(prefix=[f"{source_name}:"], index_type=IndexType.HASH)
    )
    text = ["a" * 100] * 50
    async with db.pipeline(transaction=True) as pipe:
        for i, _text in enumerate(text):
            doc = {"type": "paragraph", "page": i, "text": _text}
            await pipe.hset(f"doc:{i}", mapping=doc)
        await pipe.execute()

    print(await db.ft(source_name).search(Query("@type: paragraph").dialect(2)))

this returns Result{0 total, docs: []}.

But when I use db.hgetall I get my document as expected.

[shoang22]

Sorry, meant to post this in redis-py