$upload_batch_grpc..s:'Q3uw< ('s24c3&# UHnSv M g7fNr s r#r$r% s+7aT7s)idvectorspayloadr)rpointsrrr)rz3Batch upload failed due to rate limit. Waiting for z seconds before retrying...)messagecategory stacklevelzBatch upload failed z times. Retrying...T)rzipr PointStruct isinstancerr convert_extended_point_idconvert_vector_structrUpsert UpsertPointsr r retry_after_s UserWarningr Exception)rrrrrrrr ids_batch vectors_batch payload_batchidxvectorr+r,attemptexes r#upload_batch_grpcrDs/4+Im?H>O:%':U^0=/D+57+-M%( -$P %Q C c4<<0033C844V<#GMr2  %Q G     !!$3!'9"/   !  ( Y 2) $ MbN^N^M__z{$  """ # #  .w{m;NO$  /) qLG +  s+A>C5 &C<< E92D== E9 %E44E9c\rSrSrSS\S\S\S\S\S\RS-S \RS-S \ 4S jjr \ SS\S-S\S\S\S \ S S4 S jj5r S\\ S \\SS44SjrS\\ S \\4SjrSrg)GrpcBatchUploaderQNhostportrrrrrkwargsc >X0lXlX lX@lXlXPlUb[ R"U5OSUlURSS5Ul [U[R5(a[ R"U5UlgUUlg)Nr)r_host_portr_kwargs_waitr convert_shard_key_selector_shard_key_selectorpop_timeoutr4restFilterconvert_filter_update_filter) selfrHrIrrrrrrJs r#__init__GrpcBatchUploader.__init__Rs /  &  "-  1 12D E   9d3 -55  % %m 4  rc @U(d [S5eU"SUUUUS.UD6$)Nz"Collection name could not be empty)rHrIrrr() RuntimeError)clsrrHrIrrJs r#startGrpcBatchUploader.startos;CD D +#     r[itemsc #># [SURURS.URD6n[R "U5nUHQn[ UURUURURURURURS9v MS g7f)N)rHrI)rrrrrr() r rLrMrNr PointsStubrDrrQrWrrOrS)rXrachannelrrs r#process_upload GrpcBatchUploader.process_uploadsO4::DJJO$,,O0 E#$$#'#;#;"11 ,,ZZ   sBBc#B# URU5ShvN gN7fr')re)rXras r#processGrpcBatchUploader.processs&&u---s ) rLrNrMrQrSrWrOrr)FNN)N localhosti)__name__ __module__ __qualname____firstlineno__rintbooltypesShardKeySelectorrUrrY classmethodr_rrrerh__static_attributes__r(r[r#rFrFQs<@-1         "22T9 ||d*  :'+  t           & HSM idD@P6Q .Xc].x~.r[rF)FN)& itertoolsrtimertypingrrrrr qdrant_clientr r rT&qdrant_client.common.client_exceptionsr qdrant_client.connectionr $qdrant_client.conversions.conversionr rqdrant_client.uploader.uploaderr$qdrant_client.common.client_warningsrqdrant_client.conversionsrrrrcrBatchtuplerprsrUrqrDrFr(r[r#rs++'(L0L8=;=??== :: = = --4 = ;;% = =4Z= =@B. B.r[