# UHn[TU5v M g7fN)_has_custom_shards).0r rs r migrate..7s  Rb=/::Rbsz@Migration of collections with custom shards is not supported yetz*Collections already exist in dest_client: N)_select_source_collectionsany ValueError_find_collisionsset_recreate_collection_migrate_collection)rrrrr collisionsabsent_dest_collectionsr s` rmigrater0#s&2-AQR  Rb [\\!+@J!"23c*oE/Ej\RSS2]KIM;T3&]KIM;T&cURU5n[URRSS5[R R :H$)Nsharding_method)get_collectiongetattrconfigparamsrShardingMethodCUSTOM)rr collection_infos rr#r#KsD#22?CO&&--/@$G  ' ' (r1c^UR5RnUVs/sHo3RPM snmUb<[U4SjU55(dS[ U5[ T5- 35eU$TnU$s snf)Nc3,># UH oT;v M g7fr")r$r source_collection_namess rr%-_select_source_collections..Zs N^?6 6N^sz)Source client does not have collections: )get_collections collectionsnameallr+)rrsource_collections collectionr>s @rr'r'Ss'668DDASTAS:AST# N^    n 6s;K7LsSjOk7k6l m n 3 UsA;cUR5RnUVs1sHo3RiM nnU[U5-n[ U5$s snfr")r@rArBr+list)rrdest_collectionsrEdest_collection_namesexisting_dest_collectionss rr*r*csS"224@@?OP?O__?OP 5>&&33%,,??!+!2!2!K!K"))99))LGJ4J4J,KL 55] @[@[8\]''I'*2G2G*HI&::-" [;MN+s #G)?G)rWcUR5H9up4URUUURc URO URS9 M; g)N) field_name field_schema)r[create_payload_indexr7 data_type)rr rWrj field_infos rrcrcsP #1"6"6"8 (( !1;1B1B1J--PZPaPa ) #9r1cURUSSS9upE[XUS9 Ub"URX%USS9upE[XUS9 UbM"URU5RnURU5RnXg:Xd SUSU35eg) a.Migrate collection from source client to destination client Args: collection_name (str): Collection name source_client (QdrantBase): Source client dest_client (QdrantBase): Destination client batch_size (int, optional): Batch size for scrolling and uploading vectors. Defaults to 100. T)limit with_vectors)rr r N)offsetrqrrzCMigration failed, vectors count are not equal: source vector count z, dest vector count )scrollrcount)rrr rrecords next_offsetsource_client_vectors_countdest_client_vectors_counts rr-r-s)//qW[/\G[RYZ  !,33 zPT 4  V]^  ! #0"5"5o"F"L"L + 1 1/ B H H#@Z LMhLii}X~YZZ@r1)g@)NFdr")r{)rtypingrqdrant_client._pydantic_compatrrqdrant_client.client_baserqdrant_client.httprstr PointStructintfloatrrGboolr0r#r'r*r,dictPayloadIndexInforcr-r=r1rrs @0% N NN V'' (N N  N  N:*."' %U%U%U3i$&%U %U  %U  %UPj34EI  15cT1A  #Y  +*+S +dSVi+#O#O#O#O #OL      f5556    " ZZZZ Z  Zr1