+ #qj(Rt^RIt^RIt^RIHtHt^RIHt^RIH t H t H t H t H t Ht^RIHtHt^RIHt^RIHt^RIHt^R IHt^R IHtHtHtHt^R IH t H!t!H"t"] !R R .R7t#]PH!]%4t&Rt'R*RRllt(!RR]4t)!RR]4t*]#PWR] !](4.R7] !^^^R73RRll4t,]#PWR] !](4.R7RRl4t-!RR]4t.!R R!]4t/]#PWR"] !](4.R7] !^^^R73R#R$ll4t0]#PWR%] !](4.R7R&R'l4t1R(R)lt2R#)+uFila de conteúdo do registo comercial, servida a trabalhadores remotos. Existe por uma razão só: **o que é escasso é o IP, não o processador.** O ritmo de pedidos ao portal do IRN é limitado de propósito para não parecermos um ataque, e esse tecto é por endereço. Um segundo trabalhador na mesma máquina não adianta nada; um que saia por outra linha duplica a recolha sem que nenhum dos dois se porte pior. Faltavam 805 mil actos por abrir e o CT sozinho levava sete dias e meio. **O trabalhador remoto só busca HTML.** Quem parseia e escreve arestas continua a ser este processo, e isso não é detalhe de arrumação: no dia em que o `REGISTRY_PARSE_VERSION` sobe — subiu hoje, para 2 — uma máquina lá fora com a versão antiga escreveria dados desactualizados sem nada acusar. Assim o parser está num sítio só, e o trabalhador não conhece a base de dados nem precisa de credenciais dela. A fila já estava preparada: `take_content` reclama com `FOR UPDATE SKIP LOCKED` e devolve sozinha os actos reclamados há mais de 15 minutos. Um trabalhador que morra a meio não perde nada — só atrasa aqueles actos um quarto de hora. N) AnnotatedAny)UUID) APIRouterDependsHeader HTTPExceptionQuerystatus) BaseModelField)text) AsyncSession) get_session) app_settings)ingest_contentpublication_payloadrelease_content take_content)finish_queue_itemingest_publicationstake_from_queuez /registryz public-api)prefixtagsregistry_worker_keyc V^8dQhR\\\\43,R\\R,\ RR73,RR/#)session x_worker_keyNz X-Worker-Key)aliasreturn)rrrrstrr)formats"app/api/v1/registry_work.py __annotate__r$7sM T T |W[%99 : TC$J^(DDE T  Tc0"\P!V\4GRjxL pV'g\\P RR7hV'd'\ P!V\V44'g\\PRR7hR#Lr5i)Nu4recolha remota desligada: não há chave configurada)detailuchave inválida) rget SETTING_KEYrr HTTP_503_SERVICE_UNAVAILABLEsecretscompare_digestr!HTTP_401_UNAUTHORIZED)rrexpecteds&& r#require_worker_keyr/7sr"%%g{;;H   / /I  w55lCMRRF88ARSS Sr?r rLrKr@rArBrCs@r#rErEUs#DRHGr%rEz/claim) dependencies)gelecV^8dQhR\\\\43,R\R\ \ \3,/#rrnr rrrrintdictr!r)r"s"r#r$r$Zs= |W[%99 :  #s(^r%c "\WR7GRjxL pVP4GRjxL RVUu.uFpRVR,R\V4/NK up/#LDL.uupi5i)u Reclama actos da fila e devolve o que é preciso para os ir buscar. O trabalhador recebe o `id` (para depois entregar) e a publicação tal como o `content_for` a consome. Nada mais: nem NIPC para cruzar, nem o corpo de outros actos, nem contexto da base de dados. limitNactsr3id publication)rcommitr)rrTbatchacts&& r#claimraYslw0 0E ..  s4y-1DS1I J   1 s0A AA A A AA A A z/delivercV^8dQhR\R\\\\43,R\ \ \3,/#rpayloadrr )rErrrrrWr!rV)r"s"r#r$r$os=)) ) |W[%99 :) #s(^)r%c "R^R^R^R^R^/pVPEFrp\WP4GRjxL pV'gVR;;,^, uu&K@VP'd7\ WPRRR7GRjxL VR;;,^, uu&MVP 'gVP 'dQ\ VVPVP VP '*R7GRjxL VR;;,^, uu&M]\WVP4GRjxL pVR;;,VR ,, uu&VR;;,^VR ,, , uu&VP4GRjxL EKu V#EL]ELLLjL \dpTP4GRjxL \PR TPT4\ YP\T4R R7GRjxL TP4GRjxL TR;;,^, uu&Rp?EK)Rp?ii;i5i) uJRecebe o HTML buscado e fecha cada acto. Cada resultado é tratado à parte e com commit próprio: um acto cujo parse rebente não pode arrastar consigo os outros nove que vieram bem. É idempotente — reentregar o mesmo corpo reescreve as mesmas arestas, que é o que o `apply_parse` já garante ao apagar por `source_act_id`. guardadosvazioserros devolvidos desconhecidosNF)r5 count_attemptvazioz$entrega remota do acto %s falhou: %sT)rK_act_forr3r7rr6r5rr4r^ Exceptionrollbackloggerwarningr!)rdrtotalsitemr`countses&& r#deliverrvns1h7A|QYZ [FWkk22 ? #q ( #  !}}}%g{{$V[\\\|$)$%%%%KK**&*&:&:":  w1$-gDIIFFx F7O3 {#q6'?'::#.." " "- : M93]G # !""$ $ $ NNA4;;PQ R!';;c!fTXY Y Y.." " " 7Oq OO  !s5I F I I F .F  F +F 6F 5F =F>3F 1F2AF F F  I F F F F  I +I>G?A I H  I"H%#I=I I  I c\a]tRt^to]!^ R7t]!]R7tRtRt Rt V3Rlt Rt Vt R#) NipcDelivery)rH)rGNFc<V^8dQh/S[;R&S[S[S[S[3,,;R&S[R,;R&S[;R&S[;R&#)rnif publicationsNr5r6r7)r!rLrWrr8)r"r9s"r#r$NipcDelivery.__annotate__sU " tCH~&D  : !r%r;)r<r=r>r?r rzrLr{r5r6r7r@rArBrCs@r#rxrxs1"C*/t)DLE!OHr%rxc@a]tRt^to]!]^R7tV3RltRtVt R#) DeliverNipcInrFc6<V^8dQh/S[S[,;R&#rJ)rLrx)r"r9s"r#r$DeliverNipcIn.__annotate__s , Lr%r;NrNrCs@r#r~r~s"'"LGr%r~z /claim-nipccV^8dQhR\\\\43,R\R\ \ \3,/#rSrU)r"s"r#r$r$sB Z Z |W[%99 : Z  Z #s(^ Zr%c "\WR7GRjxL pVP4GRjxL RVUu.uFpRVR,RVR,/NK up/#LBL,uupi5i)uReclama entidades da fila do histórico por NIPC. Lotes pequenos por defeito: cada NIPC são uma a trinta chamadas ao IRN, conforme o histórico, e um lote grande fica reclamado muito tempo. A recuperação de reclamações penduradas existe, mas é melhor não a exercitar. rYNentitiesrzdepth)rr^)rrTr_rss&& r# claim_nipcrs]"'3 3E ..  RWXRW$%egtG}ERWX YY 4Xs0AAAA AAAAAz /deliver-nipccV^8dQhR\R\\\\43,R\ \ \3,/#rc)r~rrrrrWr!rV)r"s"r#r$r$s=.. . |W[%99 :. #s(^.r%c "R^R^R^R^/pVPEFpVP;'gRP4p\V4^ 8wdVR;;,^, uu&KOVP'd-\ WRRR7GRjxL VR;;,^, uu&MVP 'd-\ WRR R7GRjxL VR;;,^, uu&MVP'd7\ WR VPR7GRjxL VR;;,^, uu&Mn\WVPR R 7GRjxL p\ WR VR7GRjxL VR;;,VR,, uu&VR;;,VR,, uu&VP4GRjxL EK V#EL.LLLxLdL \dpTP4GRjxL \PRYF4\ YR \T4R,R7GRjxL TP4GRjxL TR;;,^, uu&Rp?EKDRp?ii;i5i)uRecebe a listagem de cada NIPC e fecha-o na fila. **Sem rede deste lado**: o `ingest_publications` grava os actos como `pending` e a fila de conteúdo abre-os depois, pela escada de prioridades que já põe a cap table mais recente à frente do resto do histórico. Commit por entidade, como na entrega de conteúdo: um NIPC cuja escrita rebente não pode arrastar os outros do lote. listados actos_novosrhripendingN)r r5IrnVersionChangedr5F) fetch_contentok)r statsnovosz$entrega remota do NIPC %s falhou: %s:NiN)rKrzstriplenr7rr6r5rr{r^rnrorprqr!)rdrtotaisrsrzrrus&& r# deliver_nipcrs!]Aw< KFxx~~2$$& s8q= 7Oq O  !}}}'YdSSS|$)$%%%':M|$)$'WDJJWWWw1$1$"3"35(TOOOz"eJ&77"}%w7%.." " "3 @ M3T XP # !""$ $ $ NNA3 J#GAt U U U.." " " 7Oq OO  !s-I%8I%)G;G F: +G9G F= +G7GF?5GG GGAG.G/G3I%:G=G?GGGG I"I%G(&<II%I""I%clV^8dQhR\R\R\\\3,R,/#)rrr3r N)rr!rWr)r"s"r#r$r$s.&&L&#&$sCx.4:O&r%c "\V4TP \ R4RT/4GRjxL P 4P4pT'd \T4#R# \\\3dR#i;iLR5i)NzSELECT id::text, nipc, irn_publication_id, act_type, act_date, entity_name, listing_json FROM registry_acts WHERE id = CAST(:aid AS UUID)aid) r ValueErrorAttributeError TypeErrorexecuter mappingsfirstrW)rr3rows&& r#rmrms V oo E  FO   hj49%%  2 s7B A% BB'B B%A?;B>A??B)N)3__doc__loggingr+typingrruuidrfastapirrrrr r pydanticr r sqlalchemyr sqlalchemy.ext.asynciorapp.dbr app.servicesrapp.services.registry_sweeprrrrapp.services.registry_syncrrrrouter getLoggerr<rpr)r/r1rEpostrarvrxr~rrrmr;r%r#rss(!LL%/%  +\N ;   8 $ $  T y I IXW-?%@$AB1r "C(Zw/A'B&CD)E)X9MIM]'2D*E)FG1r " ZH Z_G4F,G+HI.J.b&r%