o i4@sddlZddlZddlmZddlmZmZmZmZm Z m Z m Z ddl m Z mZmZmZddlmZddlmZddlmZdd lmZmZmZdd lmZd d lmZd Ze edZ!GdddeZ"GdddeZ#de#de$fddZ%ddZ&ddZ'dS)N)islice)AnyCallableDictIterableListOptionalSequence)ConfigModel Optimizerset_dropout_rate)Errors)Language)Doc)Examplevalidate_examplesvalidate_get_examples)Vocab) TrainablePipez [model] @architectures = "spacy.HashEmbedCNN.v2" pretrained_vectors = null width = 96 depth = 4 embed_size = 2000 window_size = 1 maxout_pieces = 3 subword_features = true modelc @s(eZdZdZd-dedededdfdd Zede d fd d Z ede efd dZ dd deddfddZ dd dede fddZd.ddZdeefddZdeeddfddZdddddeeded eed!eeeeffd"d#Zd.d$d%Zdd&d'egeefd(eefd)d*Zd+d,ZdS)/Tok2VecaAApply a "token-to-vector" model and set its outputs in the doc.tensor attribute. This is mostly useful to share a single subnetwork between multiple components, e.g. to have one embedding and CNN network shared between a parser, tagger and NER. In order to use the `Tok2Vec` predictions, subsequent components should use the `Tok2VecListener` layer as the tok2vec subnetwork of their model. This layer will read data from the `doc.tensor` attribute during prediction. During training, the `Tok2Vec` component will save its prediction and backprop callback for each batch, so that the subsequent components can backpropagate to the shared weights. This implementation is used because it allows us to avoid relying on object identity within the models to achieve the parameter sharing. tok2vecvocabrnamereturnNcCs"||_||_||_i|_i|_dS)aInitialize a tok2vec component. vocab (Vocab): The shared vocabulary. model (thinc.api.Model[List[Doc], List[Floats2d]]): The Thinc Model powering the pipeline component. It should take a list of Doc objects as input, and output a list of 2d float arrays. name (str): The component instance name. DOCS: https://spacy.io/api/tok2vec#init N)rrr listener_mapcfg)selfrrrr!J/home/ubuntu/.local/lib/python3.10/site-packages/spacy/pipeline/tok2vec.py__init__-s   zTok2Vec.__init__Tok2VecListenercsfddjDS)zuRETURNS (List[Tok2VecListener]): The listener models listening to this component. Usually internals. cs g|] }j|D]}|q qSr!)r).0cmr r!r" Cs z%Tok2Vec.listeners..)listening_componentsr(r!r(r" listeners>szTok2Vec.listenerscCst|jS)zoRETURNS (List[str]): The downstream components listening to this component. Usually internals. )listrkeysr(r!r!r"r*EszTok2Vec.listening_componentslistenercomponent_namecCs4|j|g||j|vr|j||dSdS)z=Add a listener for a downstream component. Usually internals.N)r setdefaultappendr r.r/r!r!r" add_listenerLszTok2Vec.add_listenercCsB||jvr||j|vr|j|||j|s|j|=dSdS)z@Remove a listener for a downstream component. Usually internals.TF)rremover2r!r!r"remove_listenerRs  zTok2Vec.remove_listenercCsVd|jf}tt|ddtr'|jD]}t|tr&|j|vr&|||jqdSdS)aWalk over a model of a processing component, looking for layers that are Tok2vecListener subclasses that have an upstream_name that matches this component. Listeners can also set their upstream_name attribute to the wildcard string '*' to match any `Tok2Vec`. You're unlikely to ever need multiple `Tok2Vec` components, so it's fine to leave your listeners upstream_name on '*'. *rN) r isinstancegetattrr rwalkr$ upstream_namer3)r componentnamesnoder!r!r"find_listeners]s zTok2Vec.find_listenersdocscsBtdd|Dsjdfdd|DSj|}|S)a?Apply the pipeline's model to a batch of docs, without modifying them. Returns a single tensor for a batch of documents. docs (Iterable[Doc]): The documents to predict. RETURNS: Vector representations for each token in the documents. DOCS: https://spacy.io/api/tok2vec#predict css|]}t|VqdSN)lenr%docr!r!r" usz"Tok2Vec.predict..nOcsg|] }jjdfqS)r)ropsallocrBr widthr!r"r)xsz#Tok2Vec.predict..)anyrget_dimpredict)r r?tokvecsr!rHr"rLls   zTok2Vec.predictcCs4t||D]\}}|jdt|ksJ||_qdS)zModify a batch of documents, using pre-computed scores. docs (Iterable[Doc]): The documents to modify. tokvecses: The tensors to set, produced by Tok2Vec.predict. DOCS: https://spacy.io/api/tok2vec#set_annotations rN)zipshaperAtensor)r r? tokvecsesrCrMr!r!r"set_annotations|szTok2Vec.set_annotations)dropsgdlossesexamplesrTrUrVc sdurit|ddd|D}tj|j|\fddDjdfddfd d }t|}jdd D] }| |qOjrfjd  ||S) aLearn from a batch of documents and gold-standard information, updating the pipe's model. examples (Iterable[Example]): A batch of Example objects. drop (float): The dropout rate. sgd (thinc.api.Optimizer): The optimizer. losses (Dict[str, float]): Optional record of the loss during training. Updated using the component name as the key. RETURNS (Dict[str, float]): The updated losses dictionary. DOCS: https://spacy.io/api/tok2vec#update NTok2Vec.updatecSsg|]}|jqSr!) predicted)r%egr!r!r"r)sz"Tok2Vec.update..cg|] }jjj|jqSr!rrFalloc2frOr%t2vr(r!r"r)rScsZtt|D]}|||7<jt||d7<qfddDS)zAccumulate tok2vec loss and gradient. This is passed as a callback to all but the last listener. Only the last one does the backprop. rcr[r!r\r^r(r!r"r)r`z?Tok2Vec.update..accumulate_gradient..)rangerArfloatsum) one_d_tokvecsi) d_tokvecsrVr rMr!r"accumulate_gradients$z+Tok2Vec.update..accumulate_gradientcs&|}dur|S)z>Callback to actually do the backprop. Passed to last listener.N) finish_update)rdd_docs)rg bp_tokvecsrfr rUr!r"backprops  z Tok2Vec.update..backprop) rr r begin_updater0rr$ get_batch_idr+receive) r rWrTrUrVr?rkbatch_idr.r!)rgrjrfrVr rUrMr"updates    rXcCsdSr@r!)r rWscoresr!r!r"get_losszTok2Vec.get_loss)nlp get_examplesrucCsVt|dg}t|dD]}||jq |s"Jtjj|jd|jj |ddS)atInitialize the pipe for training, using a representative set of data examples. get_examples (Callable[[], Iterable[Example]]): Function that returns a representative sample of gold-standard Example objects. nlp (Language): The current nlp object the component is part of. DOCS: https://spacy.io/api/tok2vec#initialize Tok2Vec.initialize r)XN) rrr1xrE923formatrr initialize)r rvru doc_sampleexampler!r!r"r~s rwcCstr@)NotImplementedError)r labelr!r!r" add_labelrtzTok2Vec.add_label)r)rN) __name__ __module__ __qualname____doc__rr strr#propertyrr+r*r3boolr5r>rrrLr rRrrbrr rrqrsrrr~rr!r!r!r"rs@  6 rc@sdeZdZdZdZdededdfddZed e e defd d Z d eddfd dZ de fddZdS)r$a$A layer that gets fed its answers from an upstream connection, for instance from a component earlier in the pipeline. The Tok2VecListener layer is used as a sublayer within a component such as a parser, NER or text categorizer. Usually you'll have multiple listeners connecting to a single upstream Tok2Vec component, that's earlier in the pipeline. The Tok2VecListener layers act as proxies, passing the predictions from the Tok2Vec component into downstream components, and communicating gradients back upstream. ztok2vec-listenerr:rIrNcCs4tj||jtd|id||_d|_d|_d|_dS)a upstream_name (str): A string to identify the 'upstream' Tok2Vec component to communicate with. The upstream name should either be the wildcard string '*', or the name of the `Tok2Vec` component. You'll almost never have multiple upstream Tok2Vec components, so the wildcard string will almost always be fine. width (int): The width of the vectors produced by the upstream tok2vec component. rE)rforwarddimsN)r r#rrr: _batch_id_outputs _backprop)r r:rIr!r!r"r#s   zTok2VecListener.__init__inputscCstdd|DS)zCalculate a content-sensitive hash of the batch of documents, to check whether the next batch of documents is unexpected. css"|] }tdd|DVqdS)css|]}|jVqdSr@)orth)r%tokenr!r!r"rDsz9Tok2VecListener.get_batch_id...NrcrBr!r!r"rDs z/Tok2VecListener.get_batch_id..r)clsrr!r!r"rnszTok2VecListener.get_batch_idrpcCs||_||_||_dS)zStore a batch of training predictions and a backprop callback. The predictions and callback are produced by the upstream Tok2Vec component, and later will be used when the listener's component's model is called. N)rrr)r rpoutputsrkr!r!r"ros zTok2VecListener.receivecCsL|jdur|jdurttj||}||jkr$ttjj||jddS)z_Check that the batch of Doc objects matches the ones we have a prediction for. N)id1id2T)rr ValueErrorrE954rnE953r})r rrpr!r!r" verify_inputs s    zTok2VecListener.verify_inputs)rrrrrrintr# classmethodrrrnrorrr!r!r!r"r$s  r$is_traincCs|r2|jdur'g}|D]}|jjdkrttjjdd||jq |tfS| ||j |j fSg}| d}|D]}|jjdkrP||j t||q;||jq;|tfS)z7Supply the outputs from the upstream Tok2Vec component.NrrryrE)rrPsizerrE203r}r1_empty_backproprrrrKrFr]rA)rrrrrCrIr!r!r"rs"      rcCsgSr@r!)dXr!r!r"r<rtrcCs,|dkr td}|jStdtd|)N make_tok2veczspacy.pipeline.factorieszmodule z has no attribute ) importlib import_modulerAttributeErrorr)rmoduler!r!r" __getattr__As r)(rsys itertoolsrtypingrrrrrrr thinc.apir r r r errorsrlanguagertokensrtrainingrrrrrtrainable_piperdefault_model_configfrom_strDEFAULT_TOK2VEC_MODELrr$rrrrr!r!r!r"s& $      ?<%