§
    ˜Štj\  ã                   óœ  — d dl Z d dlZd dlmZ d dlZd dlZd dlmZmZm	Z	m
Z
mZ d dlmZ d dlmZ d dlmZ d dlZd dlZd dlmZmZ d dlmZmZ d dlmZ d d	lmZ d dlm c m!c mZ d dl"m c m!c m#Z# d d
lm$Z$ d dl%m&Z&m'Z'm(Z( d dl)m*Z*m+Z+m,Z,m-Z-m.Z. d dl/Z/d dl0m1Z2 d dl3m4Z4 d dl5Z6d dl7Z7eg ef         Z8de/j9        v r! eddddddd e7j:        ¦   «         ¬¦  «        gn  eddddddd e7j:        ¦   «         ¬¦  «        gZ; ej<        de;¬¦  «        dej=        deeddf         fd„¦   «         Z> ej?         ej@        d ejA        d¦  «        dd¬¦  «        d¬¦  «        ZBejC        dejD        de
ejE        ejF        f         fd „¦   «         ZG e ejH         eG¦   «         d!d"„ d#„ f¬$¦  «        ¬%¦  «        d&ed'e	e
ejE        ejF        f                  ddfd(„¦   «         ZId&eddfd)„ZJd&ed*eKd+ejF        d,eddf
d-„ZLd.„ ZM G d/„ d0e&¦  «        ZNd1ZO G d2„ d3e(¦  «        ZPd4ejQ        d&eddfd5„ZRd4ejQ        d&eddfd6„ZSd&eddfd7„ZTd4ejQ        d&eddfd8„ZUdS )9é    N)Ú
Connection)Ú	GeneratorÚCallableÚListÚTupleÚcast)ÚUUID)Úgiven)Ú	ClientAPIÚ	ServerAPI)ÚSettingsÚSystem)ÚVectorReader)ÚLocalSegmentManager)Úhashing_embedding_function)ÚEmbeddingStateMachineStatesÚtraceÚEmbeddingStateMachineBase)Úrun_state_machine_as_testÚruleÚpreconditionÚ
initializeÚMultipleResults)ÚClient)ÚDefaultEmbeddingFunctionÚCHROMA_RUST_BINDINGS_TEST_ONLYz!chromadb.api.rust.RustBindingsAPIz chromadb.db.impl.sqlite.SqliteDBz7chromadb.segment.impl.manager.local.LocalSegmentManagerT)Úchroma_api_implÚchroma_sysdb_implÚchroma_producer_implÚchroma_consumer_implÚchroma_segment_manager_implÚallow_resetÚis_persistentÚpersist_directoryzchromadb.api.segment.SegmentAPIÚmodule)ÚscopeÚparamsÚrequestÚreturnc              #   ó   K  — | j         V — d S ©N)Úparam)r(   s    úa/var/www/html/CA-Chatbot/venv/lib/python3.11/site-packages/chromadb/test/property/test_persist.pyÚsettingsr.   D   s   è è € à
Œ-ÐÐÐÐÐó    é
   ©Úwith_hnsw_paramsÚwith_persistent_hnsw_paramsÚmax_hnsw_batch_sizeÚmax_hnsw_sync_thresholdÚcoll)ÚkeyÚdrawc                 óÎ   —  | t          j        dt          j        d¦  «        dd¬¦  «        ¦  «        } | t          j        t          j        |¦  «        ¦  «        ¦  «        }||fS )NTr0   r1   )Ú
strategiesÚcollectionsÚstÚjustÚ
recordsets)r8   Ú
collectionÚ	recordsets      r-   Ú!collection_and_recordset_strategyrA   V   so   € ð �ÝÔØ!Ý(*¬°©¬à "Ø$&ð	
ñ 	
ô 	
ñô €Jð �•ZÔ*­2¬7°:Ñ+>Ô+>Ñ?Ô?Ñ@Ô@€IØ�yÐ Ð r/   é   c                 ó   — | d         j         S ©Nr   ©Úname©Úxs    r-   ú<lambda>rI   k   s   € ˜Q˜qœTœY€ r/   c                 ó   — | d         j         S rD   rE   rG   s    r-   rI   rI   k   s   € °!°A´$´)€ r/   )Úmin_sizeÚ	unique_by)Ú#collection_and_recordset_strategiesr.   rM   c                 óì  — t          | ¦  «        }|                     ¦   «          t          j        |¦  «        }|                     ¦   «          |D ]©\  }}|                     |j        |j        |j        ¬¦  «        } |j	        di |¤Ž t          j        ||¦  «         t          j        ||¦  «         t          j        ||¦  «         t          j        ||¦  «         t          j        |||j        ¬¦  «         Œª|                     ¦   «          ~~t          | ¦  «        }|                     ¦   «          t          j        |¦  «        }|D ]–\  }}|                     |j        |j        ¬¦  «        }t          j        ||¦  «         t          j        ||¦  «         t          j        ||¦  «         t          j        ||¦  «         t          j        |||j        ¬¦  «         Œ—|                     ¦   «          ~~d S )N©rF   ÚmetadataÚembedding_function)rQ   ©rF   rQ   © )r   ÚstartÚClientCreatorÚfrom_systemÚresetÚcreate_collectionrF   rP   rQ   ÚaddÚ
invariantsÚcountÚmetadatas_matchÚdocuments_matchÚ	ids_matchÚann_accuracyÚstopÚget_collection)	r.   rM   Úsystem_1Úclient_1Úcollection_strategyÚrecordset_strategyr6   Úsystem_2Úclient_2s	            r-   Útest_persistrh   g   s5  € õ �hÑÔ€HØ‡N‚NÑÔÐÝÔ(¨Ñ2Ô2€Hà‡N‚NÑÔÐð 
-ð
ð 
ñ 	ØØà×)Ò)Ø$Ô)Ø(Ô1Ø2ÔEð *ñ 
ô 
ˆð 	ˆŒÐ&Ð&Ð%Ð&Ð&Ð&åÔ˜Ð1Ñ2Ô2Ð2ÝÔ" 4Ð);Ñ<Ô<Ð<ÝÔ" 4Ð);Ñ<Ô<Ð<ÝÔ˜TÐ#5Ñ6Ô6Ð6ÝÔØØØ2ÔEð	
ñ 	
ô 	
ð 	
ð 	
ð ‡M‚M�O„O€OØØå�hÑÔ€HØ‡N‚NÑÔÐÝÔ(¨Ñ2Ô2€Hð
 
-ð
ð 
ñ 	ØØà×&Ò&Ø$Ô)Ø2ÔEð 'ñ 
ô 
ˆõ 	Ô˜Ð1Ñ2Ô2Ð2ÝÔ" 4Ð);Ñ<Ô<Ð<ÝÔ" 4Ð);Ñ<Ô<Ð<ÝÔ˜TÐ#5Ñ6Ô6Ð6ÝÔØØØ2ÔEð	
ñ 	
ô 	
ð 	
ð 	
ð ‡M‚M�O„O€OØØˆˆr/   c                 óØ  ‡— t          | ¦  «        }|                     ¦   «          t          j        |¦  «        }|                     ddddœ¬¦  «        }|                     t          ¦  «        }|                     |j        t          ¦  «        Šdt          fˆfd„} |¦   «         }|                     ddgd	gd
gg¬¦  «          |¦   «         |k    sJ ‚ |¦   «         }|                     dgdgg¬¦  «          |¦   «         |k    sJ ‚ |¦   «         }|                     g d¢d	gd
gdgg¬¦  «          |¦   «         |k    sJ ‚ |¦   «         }|                     dgdgg¬¦  «         |                     ddgd	gd
gg¬¦  «          |¦   «         |k    sJ ‚ |¦   «         }|                     dgdgg¬¦  «         |                     ddgd	gd
gg¬¦  «          |¦   «         |k    sJ ‚ |¦   «         }d S )NÚtesté   )úhnsw:batch_sizeúhnsw:sync_threshold)rF   rP   r)   c                  ó²   •— t          j        d¦  «         	 t          j                             ‰                      ¦   «         ¦  «        S # t          $ r Y dS w xY w)Ngš™™™™™¹?éÿÿÿÿ)ÚtimeÚsleepÚosÚpathÚgetmtimeÚ_get_metadata_fileÚFileNotFoundError)Úsegments   €r-   Úget_index_last_modified_atz7test_sync_threshold.<locals>.get_index_last_modified_atº   sY   ø€ åŒ
�3‰Œˆð	Ý”7×#Ò# G×$>Ò$>Ñ$@Ô$@ÑAÔAÐAøÝ ð 	ð 	ð 	Ø�2�2ð	øøøs   —0A Á
AÁAÚ1Ú2ç      ð?ç       @)ÚidsÚ
embeddingsÚ3ç      @)ry   rz   r   Ú4ç      @Ú5ç      @)r   rT   rU   rV   rX   Úinstancer   Úget_segmentÚidr   ÚfloatrY   Úupsert)r.   ÚsystemÚclientr?   Úmanagerrx   Úlast_modified_atrw   s          @r-   Útest_sync_thresholdrŽ   ®   s†  ø€ Ý�HÑÔ€FØ
‡L‚L�N„N€NÝÔ& vÑ.Ô.€Fà×)Ò)Ø°!ÈAÐNÐNð *ñ ô €Jð �oŠoÕ1Ñ2Ô2€GØ×!Ò! *¤-µÑ>Ô>€Gð­ð ð ð ð ð ð ð 2Ð1Ñ3Ô3Ðà‡N‚N˜˜S�z°¨u°s°e¨n€NÑ=Ô=Ð=ð &Ð%Ñ'Ô'Ð+;Ò;Ð;Ð;Ð;Ø1Ð1Ñ3Ô3Ðð ‡N‚N˜�u¨3¨%¨€NÑ1Ô1Ð1ð &Ð%Ñ'Ô'Ð*:Ò:Ð:Ð:Ð:Ø1Ð1Ñ3Ô3Ðð ×Ò˜/˜/˜/¸°u¸s¸eÀcÀUÐ6KÐÑLÔLÐLð &Ð%Ñ'Ô'Ð*:Ò:Ð:Ð:Ð:Ø1Ð1Ñ3Ô3Ðð ‡N‚N˜�u¨3¨%¨€NÑ1Ô1Ð1Ø×Ò˜3 ˜*°3°%¸#¸°ÐÑ@Ô@Ð@ð &Ð%Ñ'Ô'Ð*:Ò:Ð:Ð:Ð:Ø1Ð1Ñ3Ô3Ðð ‡N‚N˜�u¨3¨%¨€NÑ1Ô1Ð1Ø‡N‚N˜˜S�z°¨u°s°e¨n€NÑ=Ô=Ð=ð &Ð%Ñ'Ô'Ð*:Ò:Ð:Ð:Ð:Ø1Ð1Ñ3Ô3ÐÐÐr/   Úcollection_nameÚ
record_setÚconnc                 ó  — 	 t          | ¦  «        }|                     ¦   «          t          j        |¦  «        }|                     |t          j        ¦   «         ¬¦  «        }t          j        ||¦  «         t          j	        ||¦  «         t          j
        ||¦  «         t          j        ||¦  «         t          j        ||¦  «         |                     ¦   «          d S # t          $ r}|                     |¦  «         |‚d }~ww xY w)NrR   )r   rT   rU   rV   ra   r:   Ú"not_implemented_embedding_functionrZ   r[   r\   r]   r^   r_   r`   Ú	ExceptionÚsend)r.   r�   r�   r‘   rŠ   r‹   r6   Úes           r-   Úload_and_checkr—   é   sÿ   € ðÝ˜Ñ!Ô!ˆØ�Š‰ŒˆÝÔ*¨6Ñ2Ô2ˆà×$Ò$Ø Ý)ÔLÑNÔNð %ñ 
ô 
ˆõ 	Ô˜˜zÑ*Ô*Ð*ÝÔ" 4¨Ñ4Ô4Ð4ÝÔ" 4¨Ñ4Ô4Ð4ÝÔ˜T :Ñ.Ô.Ð.ÝÔ  jÑ1Ô1Ð1à�Š‰ŒˆˆˆøÝð ð ð Ø�	Š	�!‰ŒˆØˆøøøøðøøøs   ‚CC  Ã 
DÃ*DÄDc                  ó¤   — 	 t          j        d¦  «        } |                      dg¦  «         | S # t          $ r t          j        d¦  «        cY S w xY w)NÚ
forkserverÚchromadbÚspawn)ÚmultiprocessingÚget_contextÚset_forkserver_preloadr”   )Úctxs    r-   Úget_multiprocessing_contextr      sh   € ð
4õ Ô)¨,Ñ7Ô7ˆð 	×"Ò" J <Ñ0Ô0Ð0Øˆ
øÝð 4ð 4ð 4åÔ*¨7Ñ3Ô3Ð3Ð3Ð3ð4øøøs   ‚+. ®AÁAc                   ó   — e Zd ZdZdS )Ú#PersistEmbeddingsStateMachineStatesÚpersistN)Ú__name__Ú
__module__Ú__qualname__r£   rS   r/   r-   r¢   r¢     s   € € € € € Ø€G€G€Gr/   r¢   é   c                   óÊ   ‡ — e Zd Zdedefˆ fd„Z ee¬¦  «        dej	        fd„¦   «         Z e
d„ ¦  «         e¦   «         dd
„¦   «         ¦   «         Zdedd	fˆ fd„Zdd„Zˆ xZS )ÚPersistEmbeddingsStateMachiner‹   r.   c                 óº   •— || _         || _        t          | _        | j                              ¦   «          t          ¦   «                              | j         ¦  «         d S r+   )r‹   r.   Ú MIN_STATE_CHANGES_BEFORE_PERSISTÚ(min_state_changes_left_before_persistingrW   ÚsuperÚ__init__)Úselfr‹   r.   Ú	__class__s      €r-   r®   z&PersistEmbeddingsStateMachine.__init__  sM   ø€ ØˆŒØ ˆŒÝ8XˆÔ5ØŒ×ÒÑÔÐÝ‰Œ×Ò˜œÑ%Ô%Ð%Ð%Ð%r/   ©r?   r?   c                 óH  — | j                              ¦   «          | j                              |j        |j        |j        ¬¦  «        | _        |j        | _        t          d¦  «         |                      t          j
        ¦  «         t          j        g g g g ¬¦  «        | _        d S )NrO   Úinit)r}   Ú	metadatasÚ	documentsr~   )r‹   rW   rX   rF   rP   rQ   r?   r   Úon_state_changer   r   r:   ÚStateMachineRecordSetÚrecord_set_state)r¯   r?   s     r-   r   z(PersistEmbeddingsStateMachine.initialize!  sž   € àŒ×ÒÑÔÐØœ+×7Ò7Ø”ØÔ(Ø)Ô<ð 8ñ 
ô 
ˆŒð
 #-Ô"?ˆÔÝˆf‰ŒˆØ×ÒÕ8ÔCÑDÔDÐDå *Ô @Ø˜b¨B¸2ð!
ñ !
ô !
ˆÔÐÐr/   c                 óT   — t          | j        d         ¦  «        dk    o
| j        dk    S )Nr}   rB   r   )Úlenr¸   r¬   ©r¯   s    r-   rI   z&PersistEmbeddingsStateMachine.<lambda>2  s.   € •S˜Ô.¨uÔ5Ñ6Ô6¸!Ò;ð ?ØÔ9¸QÒ>ð r/   r)   Nc                 óÄ  — |                       t          j        ¦  «         | j        j        }t          j        ¦   «         \  }}t          ¦   «         }|                     t          | j
        || j        |f¬¦  «        }|                     ¦   «          |                     ¦   «          |                     ¦   «         r|                     ¦   «         }|‚|                     ¦   «          d S )N)ÚtargetÚargs)r¶   r¢   r£   r?   rF   rœ   ÚPiper    ÚProcessr—   r.   r¸   rT   ÚjoinÚpollÚrecvÚclose)r¯   r�   Úconn1Úconn2rŸ   Úpr–   s          r-   r£   z%PersistEmbeddingsStateMachine.persist1  s¾   € ð 	×ÒÕ@ÔHÑIÔIÐIØœ/Ô.ˆÝ&Ô+Ñ-Ô-‰ˆˆuÝ)Ñ+Ô+ˆØ�KŠKÝ!Ø”- °$Ô2GÈÐOð ñ 
ô 
ˆð 	
�Š‰	Œ	ˆ	Ø	�Š‰Œˆà�:Š:‰<Œ<ð 	Ø—
’
‘”ˆAØˆGà	�Š‰	Œ	ˆ	ˆ	ˆ	r/   Ú	new_statec                 ó¦   •— t          ¦   «                              |¦  «         |t          j        k    rt          | _        d S | xj        dz  c_        d S )NrB   )r­   r¶   r¢   r£   r«   r¬   )r¯   rÈ   r°   s     €r-   r¶   z-PersistEmbeddingsStateMachine.on_state_changeH  sW   ø€ Ý‰Œ×Ò 	Ñ*Ô*Ð*ØÕ;ÔCÒCÐCå0ð Ô9Ð9Ð9ð Ð9Ô9¸QÑ>Ð9Ô9Ð9Ð9r/   c                 ó8   — | j                              ¦   «          d S r+   )r‹   rW   r»   s    r-   Úteardownz&PersistEmbeddingsStateMachine.teardownQ  s   € ØŒ×ÒÑÔÐÐÐr/   )r)   N)r¤   r¥   r¦   r   r   r®   r   Úcollection_str:   Ú
Collectionr   r   r£   Ústrr¶   rË   Ú__classcell__)r°   s   @r-   r©   r©     s  ø€ € € € € ð&˜yð &°Hð &ð &ð &ð &ð &ð &ð €Z˜=Ð)Ñ)Ô)ð
 ZÔ%:ð 
ð 
ð 
ñ *Ô)ð
ð €\ð	?ð 	?ñô ð 
€T�V„Vðð ð ñ „Vñ	ô ð
ð$?¨ð ?°ð ?ð ?ð ?ð ?ð ?ð ?ðð ð ð ð ð ð ð r/   r©   Úcaplogc                 ó–   ‡‡— |                       t          j        ¦  «         t          j        ‰¦  «        Št          ˆˆfd„¦  «         d S )Nc                  ó&   •— t          ‰‰ ¬¦  «        S )N©r.   r‹   )r©   )r‹   r.   s   €€r-   rI   z/test_persist_embeddings_state.<locals>.<lambda>[  s   ø€ Õ-°xÈÐOÑOÔO€ r/   )Ú	set_levelÚloggingÚERRORrš   r   r   )rÐ   r.   r‹   s    `@r-   Útest_persist_embeddings_stater×   U  sV   øø€ ð ×Ò•W”]Ñ#Ô#Ð#ÝŒ_˜XÑ&Ô&€FÝØOÐOÐOÐOÐOñô ð ð ð r/   c                 óX  — t          j        |¦  «        }t          ||¬¦  «        }|                     t	          j        dddddddœd t          d¦  «        dt          j        i g dd	¬
¦
  «
        ¬¦  «         | 	                    ¦   «          | 
                    ¦   «          |                     ¦   «          |                     ¦   «          |                     ¦   «          |                     dgddggd gd dœ¬¦  «        \  }| 	                    ¦   «          | 
                    ¦   «          |                     ¦   «          |                     ¦   «          |                     ¦   «          |                     ddgddgddggd d gd dœ¬¦  «        \  }}| 	                    ¦   «          | 
                    ¦   «          |                     ¦   «          |                     ¦   «          |                     ¦   «          |                     |g¬¦  «         | 	                    ¦   «          |                     ¦   «          d S )NrÓ   ÚA00é€   rk   ©úhnsw:construction_efúhnsw:search_efúhnsw:Mrm   rl   z$2d3eddc7-2314-45f4-a951-47a9a8e099d2é   FT©
rF   rP   rQ   r‡   Ú	dimensionÚdtypeÚknown_metadata_keysÚknown_document_keywordsÚhas_documentsÚhas_embeddingsr±   Ú0g      ¹?g     ŒÛ?©r}   r~   r´   rµ   ©r�   ry   rz   g     PÊ?g     ü¶?g     ŒÃ¿g     ¬Ò?©r}   )rš   r   r©   r   r:   rÍ   r	   ÚnpÚfloat16r_   r[   Úfields_matchÚlog_size_below_maxÚno_duplicatesÚadd_embeddingsÚdelete_by_idsrË   )rÐ   r.   r‹   ÚstateÚembedding_ids_0Úembedding_ids_1Úembedding_ids_2s          r-   Útest_delete_less_than_krö   _  s§  € õ Œ_˜XÑ&Ô&€FÝ)°8ÀFÐKÑKÔK€EØ	×ÒÝÔ(Øà(+Ø"%ØØ'(Ø#$ðð ð  $ÝÐ:Ñ;Ô;ØÝ”*Ø "Ø$&ØØð!
ñ 
ô 
ð ñ ô ð ð( 
×ÒÑÔÐØ	‡K‚K�M„M€MØ	×ÒÑÔÐØ	×ÒÑÔÐØ	×ÒÑÔÐØ×-Ò-À#ÀÐXbÐdrÐWsÐVtð  EIð  DJð  Y]ð  :^ð  :^Ð-ñ  _ô  _Ñ€_Ø	×ÒÑÔÐà	‡K‚K�M„M€MØ	×ÒÑÔÐØ	×ÒÑÔÐØ	×ÒÑÔÐØ',×';Ò';ÐPSÐUXÈzÐkxð  {Kð  kLð  O_ð  aoð  Npð  jqð  AEð  GKð  @Lð  [_ð  H`ð  H`Ð';ñ  (aô  (aÑ$€O�_Ø	×ÒÑÔÐà	‡K‚K�M„M€MØ	×ÒÑÔÐØ	×ÒÑÔÐØ	×ÒÑÔÐØ	×Ò˜_Ð-ÐÑ.Ô.Ð.Ø	×ÒÑÔÐØ	‡N‚NÑÔÐÐÐr/   c                 óØ  — t          j        | ¦  «        }t          | |¬¦  «        }|                     t	          j        dddddddœt          ¦   «         t          d¦  «        dd i g dd	¬
¦
  «
        ¬¦  «         |                     g d¢ddgddgddggg d¢d dœ¬¦  «         | 	                    dg¬¦  «         |                     dgddggd gd dœ¬¦  «         | 
                    ¦   «          d S )NrÓ   rÙ   rÚ   rk   )rÜ   rÝ   rÞ   rl   rm   z$0851f751-2f11-4424-ab23-4ae97074887arß   FTrà   r±   )rç   ry   rz   r   )NNNrè   ré   rç   rê   rB   )rš   r   r©   r   r:   rÍ   r   r	   rð   rñ   rí   )r.   r‹   rò   s      r-   Útest_delete_add_after_persistrø   ‘  s`  € ÝŒ_˜XÑ&Ô&€FÝ)°8ÀFÐKÑKÔK€Eà	×ÒÝÔ(Øà(+Ø"%Øà#$Ø'(ðð õ  8Ñ9Ô9ÝÐ:Ñ;Ô;ØØØ "Ø$&ØØð#
ñ 
ô 
ð ñ ô ð ð, 
×Òð #�?�?Ø˜q˜6 A q 6¨A¨q¨6Ð2Ø+Ð+Ð+Øð
ð 
ð ñ ô ð ð 
×Ò˜S˜EÐÑ"Ô"Ð"Ø	×Òà�5Ø˜q˜6˜(Ø˜Øð	
ð 
ð ñ ô ð ð 
×ÒÑÔÐÐÐr/   c                 ó  — t          j        |¦  «        }t          ||¬¦  «        }|                     t	          j        dddddddœt          dt          j        ¬¦  «        t          d	¦  «        dt          j        i g d
d¬¦
  «
        ¬¦  «         | 
                    ¦   «          |                     ¦   «          |                     ¦   «          |                     ¦   «          |                     ¦   «          t          t           t"                   |                     g d¢g d¢g d¢g d¢g d¢g d¢g d¢g d¢gd d dœ¬¦  «        ¦  «        \  }}}}}}	}
| 
                    ¦   «          |                     ¦   «          |                     ¦   «          |                     ¦   «          |                     ¦   «          t'          d¦  «         |                     dgg d¢gd d dœ¬¦  «        }| 
                    ¦   «          |                     ¦   «          |                     ¦   «          |                     ¦   «          |                     ¦   «          t          t           t"                   |                     g d¢g d¢g d¢g d¢g d¢g d ¢g d!¢g d"¢g d#¢g d$¢g d%¢g d&¢g d'¢g d(¢g d)¢g d*¢g d+¢g d,¢gd d dœ¬¦  «        ¦  «        \  }}}}}}}}}}}}}}}}}| 
                    ¦   «          |                     ¦   «          |                     ¦   «          |                     ¦   «          |                     ¦   «          |                     d-d.gg d/¢g d0¢gd d gd dœ¬¦  «         | 
                    ¦   «          |                     ¦   «          |                     ¦   «          |                     ¦   «          |                     ¦   «          |                     g d1¢g d2¢g d3¢g d4¢g d5¢g d6¢g d7¢gd d dœ¬¦  «         | 
                    ¦   «          |                     ¦   «          |                     ¦   «          |                     ¦   «          |                     ¦   «          |                     ¦   «          | 
                    ¦   «          |                     ¦   «          |                     ¦   «          |                     ¦   «          |                     ¦   «          |                     d8g d9¢gd d dœ¬¦  «         | 
                    ¦   «          |                     ¦   «          |                     ¦   «          |                     ¦   «          |                     ¦   «          |                     d:d;gg d<¢g d=¢gd d gd dœ¬¦  «         | 
                    ¦   «          |                     ¦   «          |                     ¦   «          |                     ¦   «          |                     ¦   «          |                     d>d?d@dA|dBdCdDdE||dFdGdH|dIdJgg d¢g d¢g d¢g d¢g d ¢g d!¢g d"¢g d#¢g d$¢g d%¢g d&¢g d'¢g d(¢g d)¢g d*¢g d+¢g d,¢gd d dœ¬¦  «         | 
                    ¦   «          |                     ¦   «          |                     ¦   «          |                     ¦   «          |                     ¦   «          d S )KNrÓ   ÚJqzMs4pPm14crÚ   é	   é   rÛ   é\   )Údimrâ   z$45c5c816-0a90-4293-8d01-4325ff860040FTrà   r±   )ÚNÚe8r6r�   ÚYaoÚqFjA2cÚjHCvrz   )ç        r  r  )r{   r{   r{   )r|   r|   r|   )r€   r€   r€   )r‚   r‚   r‚   )r„   r„   r„   )ç      @r  r  rè   ré   z

Ú	MVu393QTc)ç      @r  r  )úCyF0Mk-Úq_FwuÚ2D2sQSFogDgPLkcfTÚSrwuQHQ6w4f51qWr2enLPQw8uKYs1ÚGÚwdztÚ5WÚ8tpsnÚfJbV7zrƒ   ÚVÚ1iFkoJXÚZw4uÚFcÚ7ÚvEEwrPÚYf)ç       @r  r  )ç      "@r  r  )ç      $@r  r  )ç      &@r  r  )ç      (@r  r  )ç      *@r  r  )ç      ,@r  r  )ç      .@r  r  )ç      0@r   r   )ç      1@r!  r!  )ç      2@r"  r"  )ç      3@r#  r#  )ç      4@r$  r$  )ç      5@r%  r%  )ç      6@r&  r&  )ç      7@r'  r'  )ç      8@r(  r(  rç   Údf_RWhR0HelOcv)ç      9@r*  r*  )ç      :@r+  r+  )Ú3RÚ9_Ú44uÚ3BÚMZCXZDSÚUelx)ç      ;@r2  r2  )ç      <@r3  r3  )ç      =@r4  r4  )ç      >@r5  r5  )ç      ?@r6  r6  )ç      @@r7  r7  ÚYlVm)ç     €@@r9  r9  ÚRk1ÚTPL)ç      A@r<  r<  )ç     €A@r=  r=  r  r	  r
  r  r  r  r  r  r  r  r  r  r  )rš   r   r©   r   r:   rÍ   r   rë   Úfloat64r	   r_   r[   rí   rî   rï   r   r   rÎ   rð   Úprintr£   rË   )rÐ   r.   r‹   rò   ró   rô   rõ   Úembedding_ids_3Úembedding_ids_4Úembedding_ids_5Úembedding_ids_6Ú_Úembedding_ids_12Úembedding_ids_17Úembedding_ids_18Úembedding_ids_22s                   r-   ÚMtest_batch_size_less_than_sync_with_duplicate_adds_results_in_skipped_seq_idsrI  Ä  sr  € õ Œ_˜XÑ&Ô&€FÝ)°8ÀFÐKÑKÔK€EØ	×ÒÝÔ(Øà(+Ø"%ØØ'(Ø#$ðð õ  :¸bÍÌ
ÐSÑSÔSÝÐ:Ñ;Ô;ØÝ”*Ø "Ø$&ØØð!
ñ 
ô 
ð ñ ô ð ð( 
×ÒÑÔÐØ	‡K‚K�M„M€MØ	×ÒÑÔÐØ	×ÒÑÔÐØ	×ÒÑÔÐõ 	Ý�ÔØ×ÒàGÐGÐGà#�O�OØ#�O�OØ#�O�OØ#�O�OØ#�O�OØ#�O�OØ#�O�Oðð "Ø!ðð ð 	ñ 	
ô 	
ñ	ô 	ñØØØØØØØð( 
×ÒÑÔÐà	‡K‚K�M„M€MØ	×ÒÑÔÐØ	×ÒÑÔÐØ	×ÒÑÔÐå	ˆ&�M„M€MØ
×
Ò
à�=Ø*˜?˜?Ð+ØØð	
ð 
ð ñ ô €Qð 
×ÒÑÔÐà	‡K‚K�M„M€MØ	×ÒÑÔÐØ	×ÒÑÔÐØ	×ÒÑÔÐõ( 	Ý�ÔØ×Òðð ð ð( $�O�OØ#�O�OØ&Ð&Ð&Ø&Ð&Ð&Ø&Ð&Ð&Ø&Ð&Ð&Ø&Ð&Ð&Ø&Ð&Ð&Ø&Ð&Ð&Ø&Ð&Ð&Ø&Ð&Ð&Ø&Ð&Ð&Ø&Ð&Ð&Ø&Ð&Ð&Ø&Ð&Ð&Ø&Ð&Ð&Ø&Ð&Ð&ð#ð& "Ø!ðQ)ð )ð 	ñ +	
ô +	
ñ.	ô .	ñ%Ø	Ø	Ø	Ø	ØØ	Ø	Ø	Ø	ØØØ	Ø	Ø	ØØ	Ø	ð` 
×ÒÑÔÐØ	‡K‚K�M„M€MØ	×ÒÑÔÐØ	×ÒÑÔÐØ	×ÒÑÔÐà	×ÒàÐ)Ð*Ø-Ð-Ð-Ð/AÐ/AÐ/AÐBØ ˜Øð	
ð 
ð ñ ô ð ð 
×ÒÑÔÐØ	‡K‚K�M„M€MØ	×ÒÑÔÐØ	×ÒÑÔÐØ	×ÒÑÔÐà	×Òà?Ð?Ð?à"Ð"Ð"Ø"Ð"Ð"Ø"Ð"Ð"Ø"Ð"Ð"Ø"Ð"Ð"Ø"Ð"Ð"ðð Øð
ð 
ð ñ ô ð ð 
×ÒÑÔÐØ	‡K‚K�M„M€MØ	×ÒÑÔÐØ	×ÒÑÔÐØ	×ÒÑÔÐØ	‡M‚M�O„O€OØ	×ÒÑÔÐØ	‡K‚K�M„M€MØ	×ÒÑÔÐØ	×ÒÑÔÐØ	×ÒÑÔÐà	×ÒàØ-Ð-Ð-Ð.ØØð	
ð 
ð ñ ô ð ð 
×ÒÑÔÐà	‡K‚K�M„M€MØ	×ÒÑÔÐØ	×ÒÑÔÐØ	×ÒÑÔÐà	×Òà˜5�>Ø-Ð-Ð-Ð/AÐ/AÐ/AÐBØ ˜Øð	
ð 
ð ñ ô ð ð 
×ÒÑÔÐà	‡K‚K�M„M€MØ	×ÒÑÔÐØ	×ÒÑÔÐØ	×ÒÑÔÐà	×Òð ØØ#Ø/Ø ØØØØØ Ø ØØØØ ØØð#ð(  ��Ø��Ø"Ð"Ð"Ø"Ð"Ð"Ø"Ð"Ð"Ø"Ð"Ð"Ø"Ð"Ð"Ø"Ð"Ð"Ø"Ð"Ð"Ø"Ð"Ð"Ø"Ð"Ð"Ø"Ð"Ð"Ø"Ð"Ð"Ø"Ð"Ð"Ø"Ð"Ð"Ø"Ð"Ð"Ø"Ð"Ð"ð#ð& ØðQ)
ð )
ð ñ +ô +ð +ðX 
×ÒÑÔÐØ	‡K‚K�M„M€MØ	×ÒÑÔÐØ	×ÒÑÔÐØ	‡N‚NÑÔÐÐÐr/   )VrÕ   rœ   Úmultiprocessing.connectionr   Úmultiprocessing.contextrp   Útypingr   r   r   r   r   Úuuidr	   Ú
hypothesisr
   Úhypothesis.strategiesr:   r<   Úpytestrš   Úchromadb.apir   r   Úchromadb.configr   r   Úchromadb.segmentr   Ú#chromadb.segment.impl.manager.localr   Ú!chromadb.test.property.strategiesrj   ÚpropertyÚ!chromadb.test.property.invariantsrZ   r   Ú&chromadb.test.property.test_embeddingsr   r   r   Úhypothesis.statefulr   r   r   r   r   rr   Úchromadb.api.clientr   rU   Ú"chromadb.utils.embedding_functionsr   Únumpyrë   ÚtempfileÚCreatePersistAPIÚenvironÚmkdtempÚconfigurationsÚfixtureÚFixtureRequestr.   Úsharedr;   r=   rÌ   Ú	compositeÚDrawFnrÍ   Ú	RecordSetrA   Úlistsrh   rŽ   rÎ   r—   r    r¢   r«   r©   ÚLogCaptureFixturer×   rö   rø   rI  rS   r/   r-   ú<module>rj     s×  ðØ €€€Ø Ð Ð Ð Ø 1Ð 1Ð 1Ð 1Ð 1Ð 1Ø Ð Ð Ð Ø €€€Ø 9Ð 9Ð 9Ð 9Ð 9Ð 9Ð 9Ð 9Ð 9Ð 9Ð 9Ð 9Ð 9Ð 9Ø Ð Ð Ð Ð Ð Ø Ð Ð Ð Ð Ð Ø "Ð "Ð "Ð "Ð "Ð "Ø €€€Ø €€€Ø -Ð -Ð -Ð -Ð -Ð -Ð -Ð -Ø ,Ð ,Ð ,Ð ,Ð ,Ð ,Ð ,Ð ,Ø )Ð )Ð )Ð )Ð )Ð )Ø CÐ CÐ CÐ CÐ CÐ CØ 6Ð 6Ð 6Ð 6Ð 6Ð 6Ð 6Ð 6Ð 6Ð 6Ð 6Ð 6Ø 6Ð 6Ð 6Ð 6Ð 6Ð 6Ð 6Ð 6Ð 6Ð 6Ð 6Ð 6Ø HÐ HÐ HÐ HÐ HÐ Hðð ð ð ð ð ð ð ð ð ð
ð ð ð ð ð ð ð ð ð ð ð ð ð ð 
€	€	€	Ø 7Ð 7Ð 7Ð 7Ð 7Ð 7Ø GÐ GÐ GÐ GÐ GÐ GØ Ð Ð Ð Ø €€€à˜B 	˜MÔ*Ð ð (¨2¬:Ð5Ð5ð 	ˆØ?Ø@Ø!CØ!CØ(aØØØ.˜hÔ.Ñ0Ô0ð		
ñ 		
ô 		
ðð ð 	ˆØ=Ø@Ø!CØ!CØ(aØØØ.˜hÔ.Ñ0Ô0ð		
ñ 		
ô 		
ð
ð ð: €„�h ~Ð6Ñ6Ô6ð�fÔ+ð °	¸(ÀDÈ$Ð:NÔ0Oð ð ð ñ 7Ô6ðð �”	Ø€JÔØØ$+ B¤G¨D¡M¤Mð Ø "ðñ ô ð 	ð
ñ 
ô 
€ð „ð!Ø
Œ)ð!à
ˆ:Ô  *Ô"6Ð6Ô7ð!ð !ð !ñ „ð!ð  €Ø(0¨¬Ø)Ð)Ñ+Ô+ØØ&Ð&Ð(;Ð(;Ð<ð)ñ )ô )ðñ ô ð=Øð=à)-ØˆjÔ# ZÔ%9Ð9Ô:ô*ð=ð
 
ð=ð =ð =ñô ð=ð@84 (ð 84¨tð 84ð 84ð 84ð 84ðvØðàðð Ô$ðð ð	ð
 
ðð ð ð ð64ð 4ð 4ðð ð ð ð Ð*Eñ ô ð ð $%Ð  ð9ð 9ð 9ð 9ð 9Ð$=ñ 9ô 9ð 9ðxØÔ$ðØ08ðà	ðð ð ð ð.ØÔ$ð.Ø08ð.à	ð.ð .ð .ð .ðd0¨Hð 0¸ð 0ð 0ð 0ð 0ðfQØÔ$ðQØ08ðQà	ðQð Qð Qð Qð Qð Qr/   