+ [gK^RIHt^RIt^RIHtHtHtHt^RIH t ^RI H t ]P!] 4t!RR4tR#)) defaultdictN)CallableDictListSet)BaseLunrException)Tokenca]tRt^ toRt/tRtRtRt] RRl4t ] R4t Rt R t R tR tR tV3R lRltRRltRRltRtRtV3RltRtVtR#)Pipelinezlunr.Pipelines maintain a list of functions to be applied to all tokens in documents entering the search index and queries ran agains the index. c<.Vn\\4VnR#N)_stackrset_skipselfs&//usr/lib/python3/dist-packages/lunr/pipeline.py__init__Pipeline.__init__s&( /:3/? c,\VP4#r )lenrrs&r__len__Pipeline.__len__s4;;rcdRPRPRVP444#)z,c38"TFqPxK R#5ir )label).0fns& r $Pipeline.__repr__..s6V+Bxx+s)formatjoinrrs&r__repr__Pipeline.__repr__s&&--chh6V$++6V.VWWrNc T;'g VPpW P9d\PRV4W!nWPVP&R#)z&Register a function with the pipeline.z+Overwriting existing registered function %sN)__name__registered_functionslogwarningr)clsr rs&&&rregister_functionPipeline.register_functionsG$$ ,, , KKEu M-/  *rc V!4pVF(pVPV,pVPV4K* V# \d\RP T44hi;i)z'Loads a previously serialised pipeline.z$Cannot load unregistered function {})r)addKeyErrorrr#)r, serialisedpipelinefn_namer s&& rload Pipeline.load)sk5!G !--g6  R " ':AA'J s 8&Ac pVF/pVPV4VPPV4K1 R#)zAdds new functions to the end of the pipeline. Functions must accept three arguments: - Token: A lunr.Token object which will be updated - i: The index of the token in the set - tokens: A list of tokens representing the set N)warn_if_function_not_registeredrappend)rargsr s&* rr0 Pipeline.add9s.B  0 0 4 KK  r "rc VPVP9# \d4\P RP \ TRT444R#i;i)zbFunction "{}" is not registered with pipeline. This may cause problems when serialising the index.rN)rr)AttributeErrorr*r+r#getattrrr s&&rr8(Pipeline.warn_if_function_not_registeredEsT 88t888 8  KKFFLfB,G  s:AAc VPV4VPPV4pVPPV^,V4R# \dp\ R4ThRp?ii;i)zLAdds a single function after a function that already exists in the pipeline.Cannot find existing_fnNr8rindexinsert ValueErrorrr existing_fnnew_fnrDes&&& rafterPipeline.afterPsd ,,V4 FKK%%k2E KK  uqy& 1 F#$=>A E Fs>A A/ A**A/c VPV4VPPV4pVPPW24R# \dp\ R4ThRp?ii;i)zOAdds a single function before a function that already exists in the pipeline. rBNrCrGs&&& rbeforePipeline.beforeZs^ ,,V4 FKK%%k2E KK  u - F#$=>A E Fs6A A' A""A'c bVPPV4R# \dR#i;i)z%Removes a function from the pipeline.N)rremoverFr?s&&rrQPipeline.removefs+  KK  r "   s  ..c6<V^8dQhRS[RS[S[,/#)r field_names)rrstr)r# __classdict__s"r __annotate__Pipeline.__annotate__ms++x+d3i+rc JVPV,PV4R#)z Make the pipeline skip the function based on field name we're processing. This relies on passing the field name to Pipeline.run(). N)rupdate)rr rUs&&&rskip Pipeline.skipms 2k*rc DVPFpV'dW PV,9dK$.p\V4FXwrVV!WeV4pV'gK\V\\ 34'dVP V4KGVPV4KZ TpK V#)a Runs the current list of functions that make up the pipeline against the passed tokens. :param tokens: The tokens to process. :param field_name: The name of the field these tokens belongs to, can be ommited. Used to skip some functions based on field names. )rr enumerate isinstancelisttupleextendr9)rtokens field_namer resultsitokenresults&&& rrun Pipeline.runus++BjJJrN:G%f-Ef-ftUm44NN6*NN6*.F!$ rc x\W4pVPV.4Uu.uFp\V4NK up#uupi)a-Convenience method for passing a string through a pipeline and getting strings out. This method takes care of wrapping the passed string in a token and mapping the resulting tokens back to strings. .. note:: This ignores the skipped functions since we can't access field names from this context. )r rjrV)rstringmetadatarhtkns&&& r run_stringPipeline.run_strings7f'$(HHeW$56$5SC$5666s7c.VnR#r )rrs&rresetPipeline.resets  rcVVPUu.uFqPNK up#uupir )rrr?s& r serializePipeline.serializes #';;/;R;///s&c<<V^8dQh/S[S[S[3,;R&#)rTr))rrVr)r#rWs"rrXrY s sH}-2 r)rrr )r( __module__ __qualname____firstlineno____doc__r)rrr% classmethodr-r5r0r8rKrNrQr\rjrprsrv__annotate_func____static_attributes____classdictcell__)rWs@rr r s 13@ X 00   # F F++: 70krr ) collectionsrloggingtypingrrrrlunr.exceptionsr lunr.tokenr getLoggerr(r*r rrrs3#,,- !V0V0r