ՑiϷSSKrSSKrSSKrSSKrSSKJr SSKJrJrJ r J r J r SSK r SSKJr SSKJr SSKJr SS KJr SS KJr SS KJr SS KJr SS KJr SSKJr SSK J!r! SSK"J#r# SSK$J%r% SSK&J'r' SSK(J)r)J*r* SSK+J,r,J-r-J.r. SSK/J0r0J1r1J2r2J3r3J4r4J5r5J6r6J7r7J8r8 /SQr9\Rt"SS\!55r;"SS\5r<\"S5"SS\<55r=\"S5"S S!\<55r>g)"N)chain)AnyDictOptionalTupleUnion)Image)logging)pipeline_requires_extra)ImageBatchSampler) ReadImage) benchmark) HPIConfig)PaddlePredictorOption)(AutoParallelImageSimpleInferencePipeline) BasePipeline) CropByBoxes)merge_tables_across_pages)assign_levels_to_parsing_res)construct_img_path gather_imgs) BaseResultPaddleOCRVLBlockPaddleOCRVLResult) convert_otsl_to_html crop_marginfilter_overlap_boxes merge_blockspost_process_for_spottingpre_process_for_spottingtokenize_figure_of_tabletruncate_repetitive_contentuntokenize_figure_of_table)image header_image footer_imagec3T^\rSrSrSrS6S\S\\S\\S\ S\\ \\\ 4\ 4S \ S S4U4S jjjr S rS7S \ \ S4S\ \ S4S\ \ S4S\ \ S4S\ \ S4S\ \ S4S\ \ S4S\ \ S4S\\\S \4SjjrS\S \ 4SjrS8SjrS9S\ \\\\R*\\R*4S \ \ S4S\ \ S4S\ \ S4S\ \ S4S\ \ S4S\ \ S4S\\ \\4S\\ S\\ \\\\4\4S\\S\\S \\ S!\\ \S4S\ \ S4S"\\S#\\S$\\S%\\S&\\S'\\S\\ S\\\S(\\S \42S)jjrS*\S \4S+jrS:S,\S-\ S.\ S/\ 4S0jjrS:S,\S1\ S2\ S3\ 4S4jjrS5rU=r $);_PaddleOCRVLPipeline6z_PaddleOCRVLPipeline PipelineNconfigdevice pp_optionuse_hpip hpi_configinitial_predictorreturnc>[TU]X#XES9 U(GajURSS5UlUR(a:URS05RSSS05nUR U5UlURSS5UlUR (aURS 05RS S S 05nURS S5n U bU S;dS5e0n URSS5=n bXS'URSS5=n bXS'URSS5=n bXS'URSS5=nbXS'UR"U40U D6UlURSS5Ul URSS5Ul URS 05RSS S05nURU5Ul URSS5Ul URSS5Ul [URSS5S9Ul[!SS 9Ul[%5UlURS!S5UlURS"S5UlURS#/S$Q5Ulgg)%a Initializes the class with given configurations and options. Args: config (Dict): Configuration dictionary containing various settings. device (str, optional): Device to run the predictions on. Defaults to None. pp_option (PaddlePredictorOption, optional): PaddlePredictor options. Defaults to None. use_hpip (bool, optional): Whether to use the high-performance inference plugin (HPIP) by default. Defaults to False. hpi_config (Optional[Union[Dict[str, Any], HPIConfig]], optional): The default high-performance inference configuration dictionary. Defaults to None. initial_predictor (bool, optional): Whether to initialize predictors. )r/r0r1r2use_doc_preprocessorT SubPipelinesDocPreprocessorpipeline_config_errorz+config error for doc_preprocessor_pipeline!use_layout_detection SubModulesLayoutDetectionmodel_config_errorz"config error for layout_det_model! model_nameN)zPP-DocLayoutV2zPP-DocLayoutV3z3model_name must be PP-DocLayoutV2 or PP-DocLayoutV3 threshold layout_nmslayout_unclip_ratiolayout_merge_bboxes_modeuse_chart_recognitionFuse_seal_recognition VLRecognitionzconfig error for vl_rec_model!format_block_contentuse_ocr_for_image_block batch_sizer)rHBGR)format use_queuesmerge_layout_blocksmarkdown_ignore_labels)numberfootnoteheaderr)footerr* aside_text)super__init__getr6create_pipelinedoc_preprocessor_pipeliner: create_modellayout_det_modelrCrD vl_rec_modelrFrGr batch_samplerr img_readerr crop_by_boxesrKrLrM)selfr.r/r0r1r2r3doc_preprocessor_configlayout_det_configr> layout_kwargsr?r@rArB vl_rec_config __class__s q/var/www/html/banglarbhumi/venv/lib/python3.13/site-packages/paddlex/inference/pipelines/paddleocr_vl/pipeline.pyrT_PaddleOCRVLPipeline.__init__:s.    (. 3I4(PD %((*0**^R*H*L*L%/1^+' 261E1E+2.)/ 3I4(PD %(($*JJ|R$@$D$D%)+OP%!/22<F !-*A3III!# !2!6!6{D!IIIV1:+."3"7"7 d"KKJ3=,/+<+@+@-t,'  $> !  '#'#<#< " *&*&B&B #  '#'#<#<  &"&":":  ! )%)%@%@ "!5!5"7!5$;!5 3#9  rf input_paramschUS(a(UR(d[R"S5 gg)a Check if the input parameters are valid based on the initialized models. Args: input_params (Dict): A dictionary containing input parameters. Returns: bool: True if all required models are initialized according to input parameters, False otherwise. r6zRSet use_doc_preprocessor, but the models for doc preprocessor are not initialized.FT)r6r error)r^rrs rdcheck_model_settings_valid/_PaddleOCRVLPipeline.check_model_settings_valids, . /8Q8Q MMd rfc 4 /n Sn [5n URSS5n U bU OSnURSS5nUbUOSn0n0n0n[S/-nU(a/O[R5nU(d US/- nUS/- nU(dUS/- n[ [ XU55GHXununnn[ UU 5nUSnURUUU 5nAAU(a[UUS /-S 9nU RU5 [ U5GHunnUS nUS nUU;dMUcM0n S n!URSU5n URSU5n/n"US :Xa;Sn![UUSU5unn n"URSU5n URSU5nOUS:Xa.U(a'Sn!URSU5n URSU5nOSU;aVUS:waPSn![U5n#U#Run$n%n&U$S:aU%S:aU#nURSU5n URSU5nOMUS:XaSn!Sn Sn S n[U5nO3US:Xa-U(a&S!n!URS"U5n URS#U5nX4n'U'U;a ////S$S%.UU''UU'S&RU5 UU'S'RU!5 UU'S(RU 5 UU'S)RUU45 U'UUU4'U RU"5 GM AGM[ AAUc0nOURS*S5cS+US*'UH}n'U'upSU US,.UEn(UU'S&nUU'S'n)[!UR"R$"[ UU)5VV*s/sH unn*UU*S-.PM sn*n4S.U (aSOS0U(D65n+AA)U+UU'S/'M /n,/n-/n./n/[ U 5GHunn/n0/n10n2[ U5GHQunnUS nUSn3US nS0n40n UU4U;GalUUU4n'UU'n5U5S1n6U6['U5S)5:aU5S)U6UU4:XdeU5S/U6n7U5S&U6n8U5S(U6n U6S2- n6U6U5S1'U8U7S3'U7RS4S05n9U9cS0n9US :XaS5OS6n:[)U9U:S79n9S8U9;aS9U9;d S:U9;aS;U9;aU9R+S5R+S?S:5R+S@S;5R+S:SA5R+S;SA5n9US:XaU9R+SU>R7UU>R85nU=[:R<"U5SF.UU0RU<5 AOPN"!-"\WI5M" MM. )%n55!%L #Gn l2y7L')$"(K!+0@BT!UJ!+0@BT!UJ#%L"g-&: 4 )5<9LB #3\ &0^^.0B& &0^^.0B& %/4I&: %/^^.0B& &0^^.0B& #k1kEU6U&< #.y#9"*..1aq5QU(0I%/^^02D& &0^^02D& % 2&1 '+ %+ %, $4   MP$QM#-h#78J#KL'12E'F*($'!+&7IJ34-9M'*!.!2!28R!@J!)%' (3w(>BI!<"i"J+0C+0C%/%7%7R%@ '..ue<$WUD1$WXu5$WXu5$WUF3$WUF3 #'*::)3););C)DJ"g-#7 #C#r>)1J"j0(r213L&140 L%/M-%#)"YYz48#(99-=t#D  ') ''0@%/ "22y7L1%.%,OH6@)(3'77"$'LLC#? :MM#35J! )  $ $%5 6  " "> 2  $ $\ 2 .,E"3J       ms+Zinputlayout_thresholdr@rArBrrK prompt_labelrepetition_penalty temperaturetop_prxryrvlm_extra_argsc + ^^^^^ ^ ^ ^ ^^^^^^^^^&^'^(^)^*^+^,^-^.^/# TRTTUUUUUUU5 m,T S:XaSOST,S'TRT,5(dSS0v U c TRn Tc0mT,S(d]T(aTOS mTR5S :XaST,S 'OTR5S :XaST,S 'TR5S;d STS35eS%U U U UU U,UUUU4 Sjjm&U UUUU,UUUUU4 Sjm'U (Ga<Sn[R "US9m.[R "US9m-[R "TR RU-S9m/[R"5m*[R"5m)[R"5m([R"5m+U)U*U.U4SjnU&U(U)U*U,U-U.U4SjnU'U(U*U+U-U/U4Sjn[R"UU4SS9nUR5 [R"USS9nUR5 [R"USS9n U R5 U (aT+R5(aT/R5(dfT/RSS9n!U!S(d[!SU!SSU!S 35eU!Sv T+R5(dMOT/R5(dMfOdTR U5HOn"[#T&"U"55n#[%U#5S:Xd[%U#55eU#Sn$T'"U$5Hn%U%v M A%A$A#A"MQ U (aT*R'5 WR)S!S9 UR+5(a[,R."S"5 WR)S!S9 UR+5(a[,R."S#5 W R)S!S9 U R+5(a[,R."S$5 ggg![Ra T+R5(aMGMf=f!U (aT*R'5 WR)S!S9 UR+5(a[,R."S"5 WR)S!S9 UR+5(a[,R."S#5 W R)S!S9 U R+5(a[,R."S$5 fff=f7f)&aD Predicts the layout parsing result for the given input. Args: input (Union[str, list[str], np.ndarray, list[np.ndarray]]): Input image path, list of image paths, numpy array of an image, or list of numpy arrays. use_doc_orientation_classify (Optional[bool]): Whether to use document orientation classification. use_doc_unwarping (Optional[bool]): Whether to use document unwarping. use_layout_detection (Optional[bool]): Whether to use layout detection. Default is None. use_chart_recognition (Optional[bool]): Whether to use chart recognition. Default is None. use_seal_recognition (Optional[bool]): Whether to use seal recognition. Default is None. layout_threshold (Optional[float]): The threshold value to filter out low-confidence predictions. Default is None. layout_nms (bool, optional): Whether to use layout-aware NMS. Defaults to False. layout_unclip_ratio (Optional[Union[float, Tuple[float, float]]], optional): The ratio of unclipping the bounding box. Defaults to None. If it's a single number, then both width and height are used. If it's a tuple of two numbers, then they are used separately for width and height respectively. If it's None, then no unclipping will be performed. layout_merge_bboxes_mode (Optional[str], optional): The mode for merging bounding boxes. Defaults to None. layout_shape_mode (Optional[str], optional): The mode for layout shape. Defaults to "auto", [ "rect", "quad","poly", "auto"] are supported. use_queues (Optional[bool], optional): Whether to use queues. Defaults to None. prompt_label (Optional[Union[str, None]], optional): The label of the prompt in ['ocr', 'formula', 'table', 'chart']. Defaults to None. format_block_content (Optional[bool]): Whether to format the block content. Default is None. repetition_penalty (Optional[float]): The repetition penalty parameter used for VL model sampling. Default is None. temperature (Optional[float]): Temperature parameter used for VL model sampling. Default is None. top_p (Optional[float]): Top-p parameter used for VL model sampling. Default is None. min_pixels (Optional[int]): The minimum number of pixels allowed when the VL model preprocesses images. Default is None. max_pixels (Optional[int]): The maximum number of pixels allowed when the VL model preprocesses images. Default is None. max_new_tokens (Optional[int]): The maximum number of new tokens. Default is None. merge_layout_blocks (Optional[bool]): Whether to merge layout blocks. Default is None. markdown_ignore_labels (Optional[list[str]]): The list of ignored markdown labels. Default is None. **kwargs (Any): Additional settings to extend functionality. Returns: PaddleOCRVLResult: The predicted layout parsing result. rectFTreturn_layout_polygon_pointsrtz0the input params for model settings are invalid!Nr:ocrr{rCrzrD)rrr}r{rrzzLayout detection is disabled (use_layout_detection=False). 'prompt_label' must be one of ['ocr', 'formula', 'table', 'chart'], but got 'z'.c3^> # U(d [U5n[S[U5U5GHfnURX"U-nURX"U-nURX"U-nUR X"U-nTR U5nTS(a[TRUTTS95nOUV s/sHn SU 0PM nn UV s/sHoSPM n n TS(aJ[TRU TTTTTSS95n [X5V Vs/sHup[XS5PM nn nOd/n U HJnU RSSSTR5S SSURS URS/S ./S .5 ML U Vs/sHn/PM nnXEXkXU4v GMi gs sn fs sn fs snn fs snf7f) Nrr6)rlrm output_imgr:F)r?r@rArBrr!r|r)cls_idrscore coordinate) input_path page_indexr|)rrange instances input_paths page_indexes page_countsr\rrWrYrrrlowerr) batch_datanew_batch_sizeidxrrrr image_arraysdoc_preprocessor_resultsarritemdoc_preprocessor_imagesr doc_pp_imgrrdoc_preprocessor_imagerrBr@rrrAmodel_settingsrr^rlrms rd _process_cv1_PaddleOCRVLPipeline.predict.._process_cvgs:!!$ZQJ@&00^7KL (44S;OP )66s>=QR (44S;OP #y9 !"89/366(9U.?70,8D07Cs+|-0 4L+3K4&3K(+""89)---3&6'10C5M.?16. *&;>3;#;6J$Jw0GH; #K*,&2I.*11.2.2341=1C1C1E12,-,-,B,H,H,K,B,H,H,K 7* %& *"3J(0B"B/A!2/AK"B!WoFQQQGA"0+ #8#Cs7B+F-.F<F-F8F-F""AF-< F(%F-c3<> # UunnnnnnnTRUUUTSTSTSTTTTTTS.TETSTS9 unn n n[UUUUUUU UU U5 HDu n n n nnnnnnnU U U URSURSUUUUUUTS . n[U5v MF g7f) NrCrDrG)rrrrxryrrL) rrrrCrDrGrrLrrr) rr page_countwidthheightdoc_preprocessor_resrrrrrr )rrrr) results_cvrrrrrrrrrrrrrr rrrrrrsingle_img_resrrryrxr rr^rrrs rd _process_vlm2_PaddleOCRVLPipeline.predict.._process_vlms? '("//.#5'&45L&M%34J%K(67P(Q*<#."",",&4 %%33H$I"3#0  !!@'("!!  &$ ##-",",399!<4::1=,@&4&4(8$0#6&4 "(775 sBB@)maxsizecP>TRU5nTR5(d7[U5nTRSU45 ATR5(dM7TR 5 g![a M[ anTRSSU45 SnAMASnAff=f)NTFr)r[is_setnextput StopIteration Exceptionr)input_all_batch_datareevent_data_loading_doneevent_shutdown queue_inputr^s rd _worker_input3_PaddleOCRVLPipeline.predict.._worker_inputs!%!3!3F!;(//11 '%).%9 $z(:;&)//11(++-)$#(;<s A00 B%= B%B  B%c8>TR5(dT RSS9nUS(dTR U5 gT"USTS(a T R RROS5HnTR SU45 AM ATR5(dMgg![Ra+ TR5(aTR 5 gMf=f![anTR SSU45 SnAgSnAff=f) N?timeoutrrr:TFcv) rrUqueueEmptyrrrYr[rHr) rrr r event_cv_processing_doner!r"r queue_cvr#r^s rd _worker_cv0_PaddleOCRVLPipeline.predict.._worker_cvs(//11!*s;  7 T**5 G$22H#I!% 5 5 C C N N%) +J%LL$ );< *+!-)//11!;;!299;;488:! !(% eT1%56s*B/AC1/9C.-C.1 D;DDc>SnTRRRnTR5(GdT/n[R"5nSnSnU[R"5U- - nUS::aOkTR US9nUS(dTRU5 SnO=URUS5 AUSSHnU[US 5- nM XQ:aOMU(agU(d(TR5(aTR5 gM[U6V s/sH"n [[R"U 55PM$ n n AT "U 5Hn TRSU 45 A M A TR5(dGMSgg![ Ra Mf=fs sn f![ an TRSS U 45 Sn A gSn A ff=f) Nr'FrTr(rr|vlm)rZr[rHrtimerUr+r,rrrrrrr from_iterabler)MAX_QUEUE_DELAY_SECS MAX_NUM_BOXESresults_cv_list start_time should_break num_boxesremaining_timerreslistsmerged_results_cv result_vlmr rr-r"event_vlm_processing_doner. queue_vlmr^s rd _worker_vlm1_PaddleOCRVLPipeline.predict.._worker_vlm2s'*$ $ 1 1 ? ? J J (//11&(O!%J#(L !I)= IIK*4**Q.!"#+<<<#GD $Aw%MM$/+/L!'..tAw7 #22#6q#9C%S\)::I$:$5!'($*3::<<599;! &)/%:)%:EU0078%:&)(*67H*IJ%MM4*<= *+J.W)//11 %{{"!"()%! ueQ&78s09F$)F*$F/F'&F'/ G9GG)targetargsdaemon)rFrHr'r(rzException from the 'rz ' worker: rr3z&Input worker did not terminate in timez#CV worker did not terminate in timez$VLM worker did not terminate in timeN)rprurKrr+Queuer[rH threadingEventThreadstartremptyrUr, RuntimeErrorrrrjoinis_aliver warning)0r^rrlrmr:rCrDrGrr@rArBrrKrrFrrrrxryrrLrMrrmax_num_batches_in_processr$r/rD thread_input thread_cv thread_vlmrrr9rr>r rr-r!r"rBr r.r#rCs0` `` ````` ` `````` ` @@@@@@@@@@rdr_PaddleOCRVLPipeline.predicts@00 (  ! #  "  '&0Ed 56..~>>NO O  J  !N45+767##%/9=56%%', kZ[gZhhjk kG QG QG QRI 8I 8V )+ &++.HIK{{+EFH **558RRI'__.N&/oo&7 #'0'8 $(1(9 % . .  82 2 h%++$E8EL    !(( 5II OO "))UKJ    " L4;;==)//BSBS!(}}S}9  7*247):d1gYO#1g 5;;==)//BSBS#'"4"4U";J&*;z+B&CO/14Jc/6JJ4!0!3J+J7!  8Z* #<""$!!!!,((**OO$LMq)%%''OO$IJ*&&((OO$JK)'!;;!4;;==! !&""$!!!!,((**OO$LMq)%%''OO$IJ*&&((OO$JK)sQH"T?1P71P=P7?P7A%P7;CT)P4,P73P44P77C TT markdown_listc2SnUHnUSUS-- nM U$)z Concatenate Markdown content from multiple pages into a single document. Args: markdown_list (list): A list containing Markdown data for each page. Returns: tuple: A tuple containing the processed Markdown text. rz markdown_texts)r^rYr[r>s rdconcatenate_markdown_pages/_PaddleOCRVLPipeline.concatenate_markdown_pagess0 C fs+;'<< ._get_img_objspyy$''W~%]#'88m$/&**+BEJJ)% *>l@ST $T22rfc >/nUHun[USUSURSS5[R"SSUS5URSS5S9nT"X15=n(aXTlUR U5 Mw U$) Nrrblock_polygon_pointsz^#+\srrr)rrrrr)rrUresubr(r)rr r>robjrrks rd_conver_blocks_to_objE_PaddleOCRVLPipeline.restructure_pages.._conver_blocks_to_objsC& .|,#(99-CT#JFF8R1GH"YYz48 'u==3= #I 3 Jrfr>rrr rNrrr:rr6r) r isinstancerrUglobal_block_idglobal_group_idrrrrr)r^r_rgrhrerrru obj_res_list one_page_resrr rrr>blocks_by_pageconcatenate_res all_page_resblksblkpage_idxrks @rdrd&_PaddleOCRVLPipeline.restructure_pagessN$ x=A I   $LlJ77+E2 .0 ]+%))*#"";G0 28 #sCCHG.$9HG33(HG9)H=G> AH(H)H)r[r]rWrFr\rYrMrLrCr6r:rGrKrDrZ)NNFNTrI)FFFNTauto)FFNNNNNNNNrNNNNNNNNNNNN)TTF)!__name__ __module__ __qualname____firstlineno____doc__rrstrrboolrrrrTrirrorprurnpndarrayfloatrintrrtupler]rerd__static_attributes__ __classcell__)rcs@rdr,r,6sW' !%59AE"&ii i12 i  i U4S>9#<=> i i iiV&7;= &+D$J&7= !t,= $D$J/ = %T4Z0 = $D$J/ = "'tTz!2= $D$J/= #4:.= !)c 3=  = ~t0$" %  B N;@/4263726599=%)QU26+1%)3726.2'+!%$($((,.26:)-3RLS$s)RZZbjj1AABRL',D$J&7RL!t, RL $D$J/ RL %T4Z0 RL$D$J/RL"'tTz!2RL#5#56RLTNRL&eE53F,L&MNRL#+3-RL$C=RLTNRLuS$Y/0RL $D$J/!RL"%UO#RL$e_%RL&'RL(SM)RL*SM+RL,! -RL.&d^/RL0!)c 31RL2!3RL6 7RLh (! ! WWW W  W4"#"' c#c#c# c#  c#c#rfr,c*\rSrSr\S5rSrSrg)_BasePaddleOCRVLPipelinei!c[$rI)r,rjs rd _pipeline_cls&_BasePaddleOCRVLPipeline._pipeline_cls"s##rfc&URSS5$)NrHr)rU)r^r.s rd_get_batch_size(_BasePaddleOCRVLPipeline._get_batch_size&szz,**rfr\N)rrrrpropertyrrrr\rfrdrr!s $$+rfrrc\rSrSrSrSrg)PaddleOCRVLPipelinei*z PaddleOCR-VLr\Nrrrrentitiesrr\rfrdrr*sHrfrc\rSrSrSrSrg)PaddleOCRVL15Pipelinei/zPaddleOCR-VL-1.5r\Nrr\rfrdrr/s!Hrfr)?r+rorKr5 itertoolsrtypingrrrrrnumpyrPILr utilsr utils.depsr common.batch_samplerr common.readerrutils.benchmarkr utils.hpirutils.pp_optionr _parallelrbaser componentsrlayout_parsing.merge_tablerlayout_parsing.title_levelrlayout_parsing.utilsrrrrrruiltsrr r!r"r#r$r%r&r'r time_methodsr,rrrr\rfrdrs  4425&("4@$BEBCC   9  g#<g#g#T+G+2 "4" "rf