Bi3PddlmZddlmZddlmZmZddlmZddl Z ddl m Z ddl mZddlmZdd l mZdd lmZdd lmZdd lmZdd lmZ ddededeej<zdedej@dzdejBdzdejDdzde#de#fdZ$GddeZ%y))count)sleep)AnyIterable)uuid4N)grpc)ResourceExhaustedResponse)SyncApis)models) BaseUploader) show_warning) common_types) GrpcToRestopenapi_clientcollection_namebatch max_retriesshard_key_selector update_filter update_modewaitreturnc |\}} } |dtDn|}| dtDn| } t|| | D cgc]L\} } } tj| t | t j r| jn| xsi| N}} } } d}||kr8 |jj|tj||||| yycc} } } w#t$r?}td|jdtd t|jYd}~nAd}~wt $r2}td |d zd td ||d z k(r||d z }Yd}~nd}~wwxYw||krʌ)Nc3BK|]}ttywN)strr.0_s f/var/www/pod-logistic/pod-ai/venv/lib/python3.12/site-packages/qdrant_client/uploader/rest_uploader.py zupload_batch..s/!UW/sc3 K|]}dywrrs r r!zupload_batch..s+aT+s )idvectorpayloadr)points shard_keyrr)rpoint_insert_operationsrz3Batch upload failed due to rate limit. Waiting for z seconds before retrying...)messagecategory stacklevelzBatch upload failed z times. Retrying...T)rziprest PointStruct isinstancenpndarraytolist points_api upsert_points PointsListr r retry_after_s UserWarningr Exception)rrrrrrrr ids_batch vectors_batch payload_batchidxr%r&r'attemptexes r upload_batchrCs/4+I}m3<3D/uw/)I/rss &L'(8=;;+/999 4:: 9 9 --4 9 ;;% 94'9 9 9x/ /rS