LKiSSKJr SSKJrJrJr SSKJrJrJ r J r J r SSK J r SSKJr SSKrS\ S\ S \4S jrS\S\ S \ 4S jr"S S \ 5r\\\/S4r"SS\ 5rg))abstractmethod)CallableOptionalSequence)OperationRecord LogRecordSeqIdVectorScalarEncoding) Component)UUIDNvectorencodingreturncFU[R:Xa1[R"U[RS9R 5$U[R :Xa1[R"U[RS9R 5$[SUR35e)z"Encode a vector into a byte array.dtypeUnsupported encoding: ) r FLOAT32nparrayfloat32tobytesINT32int32 ValueErrorvaluerrs Z/var/www/html/dynamic-report/venv/lib/python3.13/site-packages/chromadb/ingest/__init__.py encode_vectorr st>)))xxbjj199;; ^)) )xxbhh/77991(..1ABCCcU[R:Xa#[R"U[RS9$U[R :Xa#[R"U[RS9$[ SUR35e)z!Decode a byte array into a vectorrr)r rr frombufferrrrrrs r decode_vectorr$sb>)))}}V2::66 ^)) )}}V2::661(..1ABCCr!c\rSrSrSr\S\SS4Sj5r\S\SS4Sj5r\S\S\ S\ 4S j5r \S\S \ \ S\ \ 4S j5r \\S\4S j55rS rg)Producer%z4Interface for writing embeddings to an ingest stream collection_idrNcg)Nselfr(s r delete_logProducer.delete_log(s r!cg)zFTruncates the log for the given collection, removing all seen records.Nr*r+s r purge_logProducer.purge_log, r! embeddingcg)zVAdd an embedding record to the given collections log. Returns the SeqID of the record.Nr*)r,r(r3s rsubmit_embeddingProducer.submit_embedding1 r! embeddingscg)aAdd a batch of embedding records to the given collections log. Returns the SeqIDs of the records. The returned SeqIDs will be in the same order as the given SubmitEmbeddingRecords. However, it is not guaranteed that the SeqIDs will be processed in the same order as the given SubmitEmbeddingRecords. If the number of records exceeds the maximum batch size, an exception will be thrown.Nr*)r,r(r8s rsubmit_embeddingsProducer.submit_embeddings8s r!cg)zaReturn the maximum number of records that can be submitted in a single call to submit_embeddings.Nr*r,s rmax_batch_sizeProducer.max_batch_sizeCr7r!r*)__name__ __module__ __qualname____firstlineno____doc__rr r-r0rr r5rr:propertyintr>__static_attributes__r*r!rr&r&%s>     t    ! .=    ! /7/H %     r!r&c\rSrSrSr\SS\S\S\\ S\\ S\\S \4 S jj5r \S \S S4S j5r \S \ 4S j5r \S \ 4Sj5r Srg)ConsumerNz5Interface for reading embeddings off an ingest streamNr( consume_fnstartendidrcg)aRegister a function that will be called to receive embeddings for a given collections log stream. The given function may be called any number of times, with any number of records, and may be called concurrently. Only records between start (exclusive) and end (inclusive) SeqIDs will be returned. If start is None, the first record returned will be the next record generated, not including those generated before creating the subscription. If end is None, the consumer will consume indefinitely, otherwise it will automatically be unsubscribed when the end SeqID is reached. If the function throws an exception, the function may be called again with the same or different records. Takes an optional UUID as a unique subscription ID. If no ID is provided, a new ID will be generated and returned.Nr*)r,r(rKrLrMrNs r subscribeConsumer.subscribeQs0 r!subscription_idcg)zUnregister a subscription. The consume function will no longer be invoked, and resources associated with the subscription will be released.Nr*)r,rRs r unsubscribeConsumer.unsubscribeks r!cg)z9Return the minimum possible SeqID in this implementation.Nr*r=s r min_seqidConsumer.min_seqidqr2r!cg)z9Return the maximum possible SeqID in this implementation.Nr*r=s r max_seqidConsumer.max_seqidvr2r!r*)NNN)r@rArBrCrDrr ConsumerCallbackFnrr rPrTrWrZrGr*r!rrIrINs? "&#!   '   e_  TN     2 4 D   5   5  r!rI)abcrtypingrrrchromadb.typesrrr r r chromadb.configr uuidr numpyrbytesr r$r&r\rIr*r!rrds//&D&DNDuDD%D>DfD# y# Lx 23T9:+ y+ r!