[Bug]: CollectionSchema does not support num_partitions when creating schemas with partition_key_field

[juanandreas]

[Bug]: CollectionSchema does not support num_partitions when creating schemas with partition_key_field

[SimFG]

@juanandreas I checked and there should be an error in usage. You can refer to the following example:

import time
import numpy as np
from pymilvus import (
    MilvusClient,
    DataType
)

fmt = "\n=== {:30} ===\n"
dim = 8
collection_name = "hello_milvus10"
milvus_client = MilvusClient("http://localhost:19530")

has_collection = milvus_client.has_collection(collection_name, timeout=5)
if has_collection:
    milvus_client.drop_collection(collection_name)

schema = milvus_client.create_schema(enable_dynamic_field=True, partition_key_field="num")
schema.add_field("id", DataType.INT64, is_primary=True)
schema.add_field("embeddings", DataType.FLOAT_VECTOR, dim=dim)
schema.add_field("title", DataType.VARCHAR, max_length=64)
schema.add_field("num", DataType.INT64)

index_params = milvus_client.prepare_index_params()
index_params.add_index(field_name = "embeddings", metric_type="L2")
milvus_client.create_collection(collection_name, schema=schema, index_params=index_params, consistency_level="Strong", num_partitions=16)

print(fmt.format("    all collections    "))
print(milvus_client.list_collections())
print(milvus_client.list_partitions(collection_name=collection_name))

output:

[juanandreas]

Thank you! I think the documentation should clarify that num_partitions argument should be defined at client.create_collection(), not client.create_schema().

Can you share how to write into this collection using do_bulk_insert? This may be a related bug.

I am currently experiencing:

milvus.do_bulk_insert(collection_name=COLLECTION, files=list_of_files, partition_name=partition_name)

RPC error: [do_bulk_insert], <MilvusException: (code=2100, message=not allow to set partition name for collection with partition key: importing data failed)>

if I exclude the partition_name,

milvus.do_bulk_insert(collection_name=COLLECTION, files=list_of_files)

TypeError: do_bulk_insert() missing 1 required positional argument: 'partition_name'

This seems contradictory.

[SimFG]

Which package is milvus used here? Is it pymilvus.utility? in milvus.do_bulk_insert

[juanandreas]

Which package is milvus used here? Is it pymilvus.utility? in milvus.do_bulk_insert

import pymilvus

milvus = pymilvus.Milvus(host=MILVUS_HOST, port=MILVUS_PORT)
milvus.do_bulk_insert(collection_name=COLLECTION, files=list_of_files, partition_name=partition_name)

I am running 2.4.3 of pymilvus and milvus version 2.4.3

[XuanYang-cn]

/assign