Ë
    lQêj\  ã                   óÚ  — 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/jr                  v r  eddddddd e7jt                  «       ¬«      gn eddddddd e7jt                  «       ¬«      gZ; ejx                  de;¬«      dejz                  deeddf   fd„«       Z> ej~                   ej€                  d ej‚                  d«      dd¬«      d¬«      ZBej†                  dejˆ                  de
ejŠ                  ejŒ                  f   fd „«       ZG e ej�                   eG«       d!d"„ d#„ f¬$«      ¬%«      d&ed'e	e
ejŠ                  ejŒ                  f      ddfd(„«       ZId&eddfd)„ZJd&ed*eKd+ejŒ                  d,eddf
d-„ZLd.„ ZM G d/„ d0e&«      ZNd1ZO G d2„ d3e(«      ZPd4ej¢                  d&eddfd5„ZRd4ej¢                  d&eddfd6„ZSd&eddfd7„ZTd4ej¢                  d&eddfd8„ZUy)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                   –— y ­w©N)Úparam)r(   s    úh/home/oem/CyberBrain26-unified/.venv/lib/python3.12/site-packages/chromadb/test/property/test_persist.pyÚsettingsr.   D   s   è ø€ à
�-‰-Óù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 )NTr/   r0   )Ú
strategiesÚcollectionsÚstÚjustÚ
recordsets)r7   Ú
collectionÚ	recordsets      r-   Ú!collection_and_recordset_strategyr@   V   s[   € ñ Ü×ÑØ!Ü(*¯©°«à "Ø$&ô	
ó€Jñ ”Z×*Ñ*¬2¯7©7°:Ó+>Ó?Ó@€IØ�yÐ Ð ó    é   c                 ó    — | d   j                   S ©Nr   ©Úname©Úxs    r-   ú<lambda>rI   k   s   € ˜Q˜q™TŸY™Y€ rA   c                 ó    — | d   j                   S rD   rE   rG   s    r-   rI   rI   k   s   € °!°A±$·)±)€ rA   )Úmin_sizeÚ	unique_by)Ú#collection_and_recordset_strategiesr.   rM   c                 ó  — t        | «      }|j                  «        t        j                  |«      }|j	                  «        |D ]Ã  \  }}|j                  |j                  |j                  |j                  ¬«      } |j                  di |¤Ž t        j                  ||«       t        j                  ||«       t        j                  ||«       t        j                  ||«       t        j                  |||j                  ¬«       ŒÅ |j!                  «        ~~t        | «      }|j                  «        t        j                  |«      }|D ]¦  \  }}|j#                  |j                  |j                  ¬«      }t        j                  ||«       t        j                  ||«       t        j                  ||«       t        j                  ||«       t        j                  |||j                  ¬«       Œ¨ |j!                  «        ~~y )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_strategyr5   Úsystem_2Úclient_2s	            r-   Útest_persistrh   g   sÛ  € ô �hÓ€HØ‡N�NÔÜ×(Ñ(¨Ó2€Hà‡N�NÔð 
-ò
ñ 	ØØà×)Ñ)Ø$×)Ñ)Ø(×1Ñ1Ø2×EÑEð *ó 
ˆð 	ˆ�‰Ñ&Ð%Ò&ä×Ñ˜Ð1Ô2Ü×"Ñ" 4Ð);Ô<Ü×"Ñ" 4Ð);Ô<Ü×Ñ˜TÐ#5Ô6Ü×ÑØØØ2×EÑEö	
ð!
ð, ‡M�M„OØØä�hÓ€HØ‡N�NÔÜ×(Ñ(¨Ó2€Hð
 
-ò
ñ 	ØØà×&Ñ&Ø$×)Ñ)Ø2×EÑEð 'ó 
ˆô 	×Ñ˜Ð1Ô2Ü×"Ñ" 4Ð);Ô<Ü×"Ñ" 4Ð);Ô<Ü×Ñ˜TÐ#5Ô6Ü×ÑØØØ2×EÑEö	
ð
ð$ ‡M�M„OØÙrA   c                 ó0  ‡— t        | «      }|j                  «        t        j                  |«      }|j	                  ddddœ¬«      }|j                  t        «      }|j                  |j                  t        «      Šdt        fˆfd„} |«       }|j                  ddgd	gd
gg¬«        |«       |k(  sJ ‚ |«       }|j                  dgdgg¬«        |«       |kD  sJ ‚ |«       }|j                  g d¢d	gd
gdgg¬«        |«       |kD  sJ ‚ |«       }|j                  dgdgg¬«       |j                  ddgd	gd
gg¬«        |«       |kD  sJ ‚ |«       }|j                  dgdgg¬«       |j                  ddgd	gd
gg¬«        |«       |kD  sJ ‚ |«       }y )NÚtesté   )úhnsw:batch_sizeúhnsw:sync_threshold)rF   rP   r)   c                  ó¨   •— t        j                  d«       	 t        j                  j	                  ‰ j                  «       «      S # t        $ r Y y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º   sC   ø€ ä�
‰
�3Œð	Ü—7‘7×#Ñ# G×$>Ñ$>Ó$@ÓAÐAøÜ ò 	Ùð	ús   ˜,A Á	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Ü×&Ñ& vÓ.€Fà×)Ñ)Ø°!ÈAÑNð *ó €Jð �o‰oÔ1Ó2€GØ×!Ñ! *§-¡-´Ó>€Gð¬õ ñ 2Ó3Ðà‡N�N˜˜S�z°¨u°s°e¨n€NÔ=ñ &Ó'Ð+;Ò;Ð;Ð;Ù1Ó3Ðð ‡N�N˜�u¨3¨%¨€NÔ1ñ &Ó'Ð*:Ò:Ð:Ð:Ù1Ó3Ðð ×Ñš/¸°u¸s¸eÀcÀUÐ6KÐÔLñ &Ó'Ð*:Ò:Ð:Ð:Ù1Ó3Ðð ‡N�N˜�u¨3¨%¨€NÔ1Ø×Ñ˜3 ˜*°3°%¸#¸°ÐÔ@ñ &Ó'Ð*:Ò:Ð:Ð:Ù1Ó3Ðð ‡N�N˜�u¨3¨%¨€NÔ1Ø‡N�N˜˜S�z°¨u°s°e¨n€NÔ=ñ &Ó'Ð*:Ò:Ð:Ð:Ù1Ó3ÑrA   Úcollection_nameÚ
record_setÚconnc                 óô  — 	 t        | «      }|j                  «        t        j                  |«      }|j	                  |t        j                  «       ¬«      }t        j                  ||«       t        j                  ||«       t        j                  ||«       t        j                  ||«       t        j                  ||«       |j                  «        y # t        $ r}|j                  |«       |‚d }~ww xY w)NrR   )r   rT   rU   rV   ra   r9   Ú"not_implemented_embedding_functionrZ   r[   r\   r]   r^   r_   r`   Ú	ExceptionÚsend)r.   r�   r�   r‘   rŠ   r‹   r5   Úes           r-   Úload_and_checkr—   é   sÉ   € ðÜ˜Ó!ˆØ�‰ŒÜ×*Ñ*¨6Ó2ˆà×$Ñ$Ø Ü)×LÑLÓNð %ó 
ˆô 	×Ñ˜˜zÔ*Ü×"Ñ" 4¨Ô4Ü×"Ñ" 4¨Ô4Ü×Ñ˜T :Ô.Ü×Ñ  jÔ1à�‰�øÜò Ø�	‰	�!ŒØˆûðús   ‚CC Ã	C7ÃC2Ã2C7c                  óž   — 	 t        j                  d«      } | j                  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      sP   € ð
4ô ×)Ñ)¨,Ó7ˆð 	×"Ñ" J <Ô0Øˆ
øÜò 4ä×*Ñ*¨7Ó3Ò3ð4ús   ‚(+ «AÁAc                   ó   — e Zd ZdZy)Ú#PersistEmbeddingsStateMachineStatesÚpersistN)Ú__name__Ú
__module__Ú__qualname__r£   rS   rA   r-   r¢   r¢     s   „ Ø�GrA   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                   j	                  «        t
        ‰| �  | j                   «       y 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__  s:   ø€ ØˆŒØ ˆŒÜ8XˆÔ5Ø�‰×ÑÔÜ‰Ñ˜Ÿ™Õ%rA   ©r>   r>   c                 ól  — | j                   j                  «        | j                   j                  |j                  |j                  |j
                  ¬«      | _        |j
                  | _        t        d«       | j                  t        j                  «       t        j                  g g g g ¬«      | _        y )NrO   Úinit)r}   Ú	metadatasÚ	documentsr~   )r‹   rW   rX   rF   rP   rQ   r>   r   Úon_state_changer   r   r9   ÚStateMachineRecordSetÚrecord_set_state)r¯   r>   s     r-   r   z(PersistEmbeddingsStateMachine.initialize!  sŽ   € à�‰×ÑÔØŸ+™+×7Ñ7Ø—‘Ø×(Ñ(Ø)×<Ñ<ð 8ó 
ˆŒð
 #-×"?Ñ"?ˆÔÜˆfŒØ×ÑÔ8×CÑCÔDä *× @Ñ @Ø˜b¨B¸2ô!
ˆÕrA   c                 óZ   — t        | j                  d   «      dk\  xr | j                  dk  S )Nr}   rB   r   )Úlenr¸   r¬   ©r¯   s    r-   rI   z&PersistEmbeddingsStateMachine.<lambda>2  s1   € ”S˜×.Ñ.¨uÑ5Ó6¸!Ñ;ò ?Ø×9Ñ9¸QÑ>ð rA   r)   Nc                 ó²  — | j                  t        j                  «       | j                  j                  }t        j                  «       \  }}t        «       }|j                  t        | j                  || j                  |f¬«      }|j                  «        |j                  «        |j                  «       r|j                  «       }|‚|j!                  «        y )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ÑHÔIØŸ/™/×.Ñ.ˆÜ&×+Ñ+Ó-‰ˆˆuÜ)Ó+ˆØ�K‰KÜ!Ø—-‘- °$×2GÑ2GÈÐOð ó 
ˆð 	
�‰Œ	Ø	�‰Œà�:‰:Œ<Ø—
‘
“ˆAØˆGà	�‰�	rA   Ú	new_statec                 óŒ   •— t         ‰| �  |«       |t        j                  k(  rt        | _        y | xj
                  dz  c_        y )NrB   )r­   r¶   r¢   r£   r«   r¬   )r¯   rÈ   r°   s     €r-   r¶   z-PersistEmbeddingsStateMachine.on_state_changeH  s=   ø€ Ü‰Ñ 	Ô*ØÔ;×CÑCÒCä0ð Õ9ð ×9Ò9¸QÑ>Ö9rA   c                 ó8   — | j                   j                  «        y r+   )r‹   rW   r»   s    r-   Úteardownz&PersistEmbeddingsStateMachine.teardownQ  s   € Ø�‰×ÑÕrA   )r)   N)r¤   r¥   r¦   r   r   r®   r   Úcollection_str9   Ú
Collectionr   r   r£   Ústrr¶   rË   Ú__classcell__)r°   s   @r-   r©   r©     s~   ø„ ð&˜yð &°Hõ &ñ ˜=Ô)ð
 Z×%:Ñ%:ò 
ó *ð
ñ ñ	?óñ 
ƒVòó ó	ð
ð$?¨ð ?°õ ?÷rA   r©   Úcaplogc                 óŽ   ‡‡— | j                  t        j                  «       t        j                  ‰«      Št        ˆˆfd„«       y )Nc                  ó   •— t        ‰‰ ¬«      S )N©r.   r‹   )r©   )r‹   r.   s   €€r-   rI   z/test_persist_embeddings_state.<locals>.<lambda>[  s   ø€ Ô-°xÈÔO€ rA   )Ú	set_levelÚloggingÚERRORrš   r   r   )rÐ   r.   r‹   s    `@r-   Útest_persist_embeddings_stater×   U  s0   ù€ ð ×Ñ”W—]‘]Ô#Ü�_‰_˜XÓ&€FÜÜOõrA   c                 óª  — t        j                  |«      }t        ||¬«      }|j                  t	        j
                  dddddddœd t        d«      dt        j                  i g dd	¬
«
      ¬«       |j                  «        |j                  «        |j                  «        |j                  «        |j                  «        |j                  dgddggd gd dœ¬«      \  }|j                  «        |j                  «        |j                  «        |j                  «        |j                  «        |j                  ddgddgddggd d gd dœ¬«      \  }}|j                  «        |j                  «        |j                  «        |j                  «        |j                  «        |j                  |g¬«       |j                  «        |j!                  «        y )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   r9   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€EØ	×ÑÜ×(Ñ(Øà(+Ø"%ØØ'(Ø#$ñð  $ÜÐ:Ó;ØÜ—*‘*Ø "Ø$&ØØô!
ð ô ð( 
×ÑÔØ	‡K�K„MØ	×ÑÔØ	×ÑÔØ	×ÑÔØ×-Ñ-À#ÀÐXbÐdrÐWsÐVtð  EIð  DJð  Y]ñ  :^Ð-ó  _Ñ€_Ø	×ÑÔà	‡K�K„MØ	×ÑÔØ	×ÑÔØ	×ÑÔØ',×';Ñ';ÐPSÐUXÈzÐkxð  {Kð  kLð  O_ð  aoð  Npð  jqð  AEð  GKð  @Lð  [_ñ  H`Ð';ó  (aÑ$€O�_Ø	×ÑÔà	‡K�K„MØ	×ÑÔØ	×ÑÔØ	×ÑÔØ	×Ñ˜_Ð-ÐÔ.Ø	×ÑÔØ	‡N�NÕrA   c                 óš  — t        j                  | «      }t        | |¬«      }|j                  t	        j
                  dddddddœt        «       t        d«      dd i g dd	¬
«
      ¬«       |j                  g d¢ddgddgddggg d¢d dœ¬«       |j                  dg¬«       |j                  dgddggd gd dœ¬«       |j                  «        y )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   r9   rÍ   r   r	   rð   rñ   rí   )r.   r‹   rò   s      r-   Útest_delete_add_after_persistrø   ‘  s  € Ü�_‰_˜XÓ&€FÜ)°8ÀFÔK€Eà	×ÑÜ×(Ñ(Øà(+Ø"%Øà#$Ø'(ñô  8Ó9ÜÐ:Ó;ØØØ "Ø$&ØØô#
ð ô ð, 
×Ñò #Ø˜q˜6 A q 6¨A¨q¨6Ð2Ú+Øñ
ð ô ð 
×Ñ˜S˜EÐÔ"Ø	×Ñà�5Ø˜q˜6˜(Ø˜Øñ	
ð ô ð 
×ÑÕrA   c                 óþ
  — t        j                  |«      }t        ||¬«      }|j                  t	        j
                  dddddddœt        dt        j                  ¬«      t        d	«      dt        j                  i g d
d¬«
      ¬«       |j                  «        |j                  «        |j                  «        |j                  «        |j                  «        t        t         t"           |j%                  g d¢g d¢g d¢g d¢g d¢g d¢g d¢g d¢gd d dœ¬«      «      \  }}}}}}	}
|j                  «        |j                  «        |j                  «        |j                  «        |j                  «        t'        d«       |j%                  dgg d¢gd d dœ¬«      }|j                  «        |j                  «        |j                  «        |j                  «        |j                  «        t        t         t"           |j%                  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œ¬«      «      \  }}}}}}}}}}}}}}}}}|j                  «        |j                  «        |j                  «        |j                  «        |j                  «        |j%                  d-d.gg d/¢g d0¢gd d gd dœ¬«       |j                  «        |j                  «        |j                  «        |j                  «        |j                  «        |j%                  g d1¢g d2¢g d3¢g d4¢g d5¢g d6¢g d7¢gd d dœ¬«       |j                  «        |j                  «        |j                  «        |j                  «        |j                  «        |j)                  «        |j                  «        |j                  «        |j                  «        |j                  «        |j                  «        |j%                  d8g d9¢gd d dœ¬«       |j                  «        |j                  «        |j                  «        |j                  «        |j                  «        |j%                  d:d;gg d<¢g d=¢gd d gd dœ¬«       |j                  «        |j                  «        |j                  «        |j                  «        |j                  «        |j%                  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œ¬«       |j                  «        |j                  «        |j                  «        |j                  «        |j+                  «        y )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   r9   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  Ä  s{  € ô �_‰_˜XÓ&€FÜ)°8ÀFÔK€EØ	×ÑÜ×(Ñ(Øà(+Ø"%ØØ'(Ø#$ñô  :¸bÌÏ
É
ÔSÜÐ:Ó;ØÜ—*‘*Ø "Ø$&ØØô!
ð ô ð( 
×ÑÔØ	‡K�K„MØ	×ÑÔØ	×ÑÔØ	×ÑÔô 	ÜœÑØ×ÑâGâ#Ú#Ú#Ú#Ú#Ú#Ú#ðð "Ø!ñð 	ó 	
ó	ñØØØØØØØð( 
×ÑÔà	‡K�K„MØ	×ÑÔØ	×ÑÔØ	×ÑÔä	ˆ&„MØ
×
Ñ
à�=Ú*Ð+ØØñ	
ð ó €Qð 
×ÑÔà	‡K�K„MØ	×ÑÔØ	×ÑÔØ	×ÑÔô( 	ÜœÑØ×Ñòò( $Ú#Ú&Ú&Ú&Ú&Ú&Ú&Ú&Ú&Ú&Ú&Ú&Ú&Ú&Ú&Ú&ð#ð& "Ø!ñQ)ð 	ó +	
ó.	ñ%Ø	Ø	Ø	Ø	ØØ	Ø	Ø	Ø	ØØØ	Ø	Ø	ØØ	Ø	ð` 
×ÑÔØ	‡K�K„MØ	×ÑÔØ	×ÑÔØ	×ÑÔà	×ÑàÐ)Ð*Ú-Ò/AÐBØ ˜Øñ	
ð ô ð 
×ÑÔØ	‡K�K„MØ	×ÑÔØ	×ÑÔØ	×ÑÔà	×Ñâ?â"Ú"Ú"Ú"Ú"Ú"ðð Øñ
ð ô ð 
×ÑÔØ	‡K�K„MØ	×ÑÔØ	×ÑÔØ	×ÑÔØ	‡M�M„OØ	×ÑÔØ	‡K�K„MØ	×ÑÔØ	×ÑÔØ	×ÑÔà	×ÑàÚ-Ð.ØØñ	
ð ô ð 
×ÑÔà	‡K�K„MØ	×ÑÔØ	×ÑÔØ	×ÑÔà	×Ñà˜5�>Ú-Ò/AÐBØ ˜Øñ	
ð ô ð 
×ÑÔà	‡K�K„MØ	×ÑÔØ	×ÑÔØ	×ÑÔà	×Ñð ØØ#Ø/Ø ØØØØØ Ø ØØØØ ØØð#ò(  ÚÚ"Ú"Ú"Ú"Ú"Ú"Ú"Ú"Ú"Ú"Ú"Ú"Ú"Ú"Ú"ð#ð& ØñQ)
ð ô +ðX 
×ÑÔØ	‡K�K„MØ	×ÑÔØ	×ÑÔØ	‡N�NÕrA   )VrÕ   rœ   Úmultiprocessing.connectionr   Úmultiprocessing.contextrp   Útypingr   r   r   r   r   Úuuidr	   Ú
hypothesisr
   Úhypothesis.strategiesr9   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Í   Ú	RecordSetr@   Úlistsrh   rŽ   rÎ   r—   r    r¢   r«   r©   ÚLogCaptureFixturer×   rö   rø   rI  rS   rA   r-   ú<module>rj     s  ðÛ Û Ý 1Û Û ß 9Õ 9Ý Ý Ý "Û Û ß -ß ,Ý )Ý Cß 6Ó 6ß 6Ó 6Ý H÷ñ ÷
õ ó 
Ý 7Ý GÛ Û à˜B 	˜MÑ*Ð ð (¨2¯:©:Ñ5ñ 	Ø?Ø@Ø!CØ!CØ(aØØØ.˜h×.Ñ.Ó0ô		
ññ 	Ø=Ø@Ø!CØ!CØ(aØØØ.˜h×.Ñ.Ó0ô		
ð
ð ð: €‡��h ~Ô6ð�f×+Ñ+ð °	¸(ÀDÈ$Ð:NÑ0Oò ó 7ðð �—	‘	Ø€J×ÑØØ$+ B§G¡G¨D£Mð Ø "ôð 	ô
€ð ‡�ð!Ø
�)‰)ð!à
ˆ:× Ñ  *×"6Ñ"6Ð6Ñ7ò!ó ð!ñ  Ø(0¨¯©Ù)Ó+ØÙ&Ñ(;Ð<ô)ôð=Øð=à)-Øˆj×#Ñ# Z×%9Ñ%9Ð9Ñ:ñ*ð=ð
 
ò=óð=ð@84 (ð 84¨tó 84ðvØðàðð ×$Ñ$ðð ð	ð
 
óò64ôÐ*Eô ð $%Ð  ô9Ð$=ô 9ðxØ×$Ñ$ðØ08ðà	óð.Ø×$Ñ$ð.Ø08ð.à	ó.ðd0¨Hð 0¸ó 0ðfQØ×$Ñ$ðQØ08ðQà	ôQrA   