ó UB/jÒã ó<•SrSSKrSSKJs Jr SSKrSSKJ r SSK Jr SSKrSSK JrJr SSKJrJr SSKJr SSKJr SS KJr SS KJrJrJr S\S\S \S\\\S\4 Sjr S\RB4Sjr"S\RB4Sjr#S\RBS\ 4Sjr$Sr%g)a^Tests for the two-flow extractor (no LLM, no real Camelot). Covers the contract that matters for the parallel flows: the Camelot flow tags every surviving grid with an is-table verdict but never drops on it (only content-empty shells are dropped), the vision flow maps located tables to per-page VisualTables, and the DualResult page-count helpers. éN)ÚPath)ÚList)ÚClassifierResultÚMockClassifier)ÚLocatedTableÚMockGridLocator©ÚCamelotCandidate)Úcamelot)Úvision)ÚCamelotTableÚ DualResultÚVisualTableÚcidÚpageÚmarkdownÚcellsÚreturnc ó•[USXUSS9$)NÚstreamgÀX@)Úcandidate_idÚflavorrrrÚaccuracyr )rrrrs Ú./home/mande/repo/quber/tests/test_dual_flow.pyÚ _candidaters€ÜØ °ÈuÐ_cñðóÚmonkeypatchcóØ^^ •[SSSSS/SS//5m[SSS S //5m UR[SUU 4Sj5 [[ S SS95n[ R"[R"[S5U55n[U5nSoCU:HoU(Gd [R"SU4SX445S[R"5;d[R"[5(a[R"[5OSS[R"5;d[R"U5(a[R"U5OS[R"U5[R"U5S.-nSSU0-n[![R""U55eS=n=pTUSoˆR$o3R&nSo•U :Hoª(d™[R"SU 4SXY45[R"U5[R"U5[R"U5[R"U 5S.-nSSU0-n[![R""U55eS=n=n=n=p©USoˆR(nSoCULoU(d„[R"SU4SX445[R"U5[R"U5[R"U5S.-nSSU0-n[![R""U55eS=n=n=pTUSoˆR(o3R*nS o•U Loª(d™[R"S U 4S!XY45[R"U5[R"U5[R"U5[R"U 5S.-nSSU0-n[![R""U55eS=n=n=n=p©g)"Nzstream-p1-0éú!| a | b | | --- | --- | | 1 | 2 |ÚaÚbÚ1Ú2zstream-p1-1z| | | --- |ÚÚrun_camelot_flavors_parallelcó>•TT/$©N©)ÚsourceÚrealÚshells €€rÚÚFtest_camelot_flow_tags_verdict_and_never_drops_on_it.. sø€ÐVZÐ\aÑUbrFzmock-reject)Úis_tableÚreasonúx.pdf©ú==©z0%(py3)s {%(py3)s = %(py0)s(%(py1)s) } == %(py6)sÚlenÚout©Úpy0Úpy1Úpy3Úpy6úassert %(py8)sÚpy8r)zS%(py5)s {%(py5)s = %(py3)s {%(py3)s = %(py1)s.candidate }.candidate_id } == %(py8)s)r9r:Úpy5r=zassert %(py10)sÚpy10)úis not)z:%(py3)s {%(py3)s = %(py1)s.classification } is not %(py6)s©r9r:r;©Úis)zT%(py5)s {%(py5)s = %(py3)s {%(py3)s = %(py1)s.classification }.is_table } is %(py8)s)rÚsetattrÚcamelot_flowrrÚasyncioÚrunÚrun_camelot_flowrr5Ú @pytest_arÚ_call_reprcompareÚ@py_builtinsÚlocalsÚ_should_repr_global_nameÚ _safereprÚAssertionErrorÚ_format_explanationÚ candidaterÚclassificationr/)rÚ classifierr6Ú@py_assert2Ú@py_assert5Ú@py_assert4Ú@py_format7Ú@py_format9Ú@py_assert0Ú@py_assert7Ú@py_assert6Ú@py_format11r+r,s @@rÚ4test_camelot_flow_tags_verdict_and_never_drops_on_itr]shù€Üm QÐ(MÐQTÐVYÐPZÐ]`ÐbeÐ\fÐOgÓh€DÜ} a¨¸B¸4¸&ÓA€EØ×ÑœÐ&DÕFbÔcô Ô 0¸%È Ñ VÓW€JÜ +Š+”l×3Ò3´D¸³MÀ:ÓNÓ O€Cäˆs‹8ÐqÐq‰=×××Óˆ8×××××ÕŒ3×××ÑŒ3×××××Öˆs×××Ñˆs××Õˆ8××Óq××××××ÓØˆq‰6Ð9×ÑÐ9×(Ñ(Ð9¨MÐ9¨MÑ9×9×9×9Ò9Ð(×9×9Ô9ˆ6×9×9Ó9Ð×9×9Ó9Ð(×9×9Ó9¨M×9×9×9×9×9×9×9Øˆq‰6Ð,× Ñ Ð,¨Ð,¨Ð,×,×,×,Ò,Ð ×,×,Ô,ˆ6×,×,Ó,Ð ×,×,Ó,¨×,×,×,×,×,×,Õ,Øˆq‰6Ð2× Ñ Ð2×)Ñ)Ð2¨UÐ2¨UÐ2×2×2×2Ò2Ð)×2×2Ô2ˆ6×2×2Ó2Ð ×2×2Ó2Ð)×2×2Ó2¨U×2×2×2×2×2×2×2Ð2rcóh^•[SSSSS/SS//5mUR[SU4S j5 [R"[R "[ S 5SS95n[U5nSo2U:HoD(Gd [R"S U4SX#45S[R"5;d[R"[5(a[R"[5OSS[R"5;d[R"U5(a[R"U5OS[R"U5[R"U5S.-nSSU0-n[[R"U55eS=n=pCUSowR nSo2ULoD(d„[R"SU4SX#45[R"U5[R"U5[R"U5S.-nSSU0-n[[R"U55eS=n=n=pCg)Nzstream-p2-0ér r!r"r#r$r&có >•T/$r(r))r*r+s €rr-ÚFtest_camelot_flow_without_classifier_leaves_untagged...s ø€ÐVZÑU[rr1)rSrr2r4r5r6r7r<r=rrB)z6%(py3)s {%(py3)s = %(py1)s.classification } is %(py6)srA)rrDrErFrGrHrr5rIrJrKrLrMrNrOrPrR) rr6rTrUrVrWrXrYr+s @rÚ4test_camelot_flow_without_classifier_leaves_untaggedrb,sMø€Üm QÐ(MÐQTÐVYÐPZÐ]`ÐbeÐ\fÐOgÓh€DØ×ÑœÐ&DÔF[Ô\Ü +Š+”l×3Ò3´D¸³MÈdÑSÓ T€CÜˆs‹8ÐqÐq‰=×××Óˆ8×××××ÕŒ3×××ÑŒ3×××××Öˆs×××Ñˆs××Õˆ8××Óq××××××ÓØˆq‰6Ð(× Ñ Ð( DÐ( DÐ(×(×(×(Ò(Ð ×(×(Ô(ˆ6×(×(Ó(Ð ×(×(Ó( D×(×(×(×(×(×(Ö(rÚtmp_pathc óF^^•US-mUS-mTRS5 TRS5 UR[SUU4Sj5 [SSSS S SS9/n[R "[R"[S 5[U555n[U5nSoTU:Hof(Gd [R"SU4SXE45S[R"5;d[R"[5(a[R"[5OSS[R"5;d[R"U5(a[R"U5OS[R"U5[R"U5S.-nSSU0-n[![R""U55eS=n=peUV s1sHo™R$iM n n SS1oºU:HoD(do[R"SU4SX«45[R"U 5[R"U5S.-nSSU0-n[![R""U55eS=n =pKSU5n ['U 5o»(d¢SS[R"5;d[R"[&5(a[R"[&5OS[R"U 5[R"U5S.-n[![R""U55eS=pÛgs sn f)Nz page-0001.pngz page-0002.pngóxÚrender_pagescó>•TT/$r(r))r*ÚdpiÚout_dirÚp1Úp2s €€rr-ÚBtest_vision_flow_maps_located_to_per_page_tables..9sø€ÐSUÐWYÑRZrrÚt)çš™™™™™¹?rngÍÌÌÌÌÌì?gà?©rr_)rrT)ÚordinalÚtitleÚregionÚ grid_rowsÚ grid_colsÚ tightenedr1r_r2r4r5r6r7r<r=)z%(py1)s == %(py4)s)r9Úpy4zassert %(py6)sr;c3ód# •UH&oRS:H=(a URv• M( g7f)rmN)rqru)Ú.0Úvs rÚ ÚCtest_vision_flow_maps_located_to_per_page_tables..Is"é€Ð;²s°!w‰w˜#‰~×- !§+¡+Ô-²sùs‚.0z,assert %(py4)s {%(py4)s = %(py0)s(%(py2)s) }Úall)r8Úpy2rv)Úwrite_bytesrDÚvision_flowrrFrGÚrun_vision_flowrrr5rIrJrKrLrMrNrOrPrr|)rrcÚlocatedr6rTrUrVrWrXryrYÚ@py_assert3Ú@py_format5Ú@py_assert1rjrks @@rÚ0test_vision_flow_maps_located_to_per_page_tablesr…4sæù€Ø OÑ #€BØ OÑ #€BØ‡NN4ÔØ‡NN4ÔØ×Ñœ ^Õ5ZÔ[ô ØØØ'ØØØñ ð €Gô+Š+”k×1Ò1´$°w³-ÄÐQXÓAYÓZÓ [€Cäˆs‹8ÐqÐq‰=×××Óˆ8×××××ÕŒ3×××ÑŒ3×××××Öˆs×××Ñˆs××Õˆ8××Óq××××××ÓÙÓ šCqFŒF™CÐ*Ð Q¨ FÐ* FÑ*×*×*×*Ò*Ð ×*×*Ô*Ð ×*×*Ó* F×*×*×*×*×*×*Ó*Ù;±sÓ;Ð;Œ3Ð;Ó;Ð;Õ;×;×;×;×;×;Ñ;Œ3×;×;×;Ñ;Œ3×;×;Õ;Ð;×;×;Ó;Ð;×;×;×;×;×;Ó;ùò!sÇLc ód•[S[SSSSSS9[SSSSSS9[SSSSSS9/[[SSS /5S 9/S9nURo"5nSSS.o2U:HoD(dÏ[ R"S U4SX#45S[R"5;d[ R"U5(a[ R"U5OS[ R"U5[ R"U5[ R"U5S.-nSSU0-n[[ R"U55eS=n=n=pCURo"5nSS0o2U:HoD(dÏ[ R"S U4SX#45S[R"5;d[ R"U5(a[ R"U5OS[ R"U5[ R"U5[ R"U5S.-nSSU0-n[[ R"U55eS=n=n=pCg)Nr1rr%)rrrrT)rrprqrrrur_r!Úm)rQ)r*Úvisualrror2)zS%(py4)s {%(py4)s = %(py2)s {%(py2)s = %(py0)s.visual_count_by_page }() } == %(py7)sÚresult)r8r}rvÚpy7zassert %(py9)sÚpy9)zT%(py4)s {%(py4)s = %(py2)s {%(py2)s = %(py0)s.camelot_count_by_page }() } == %(py7)s)rrr rÚvisual_count_by_pagerIrJrKrLrMrNrOrPÚcamelot_count_by_page)r‰r„r‚r[rUÚ@py_format8Ú@py_format10s rÚtest_dualresult_page_countsrLsy€Ü Øä˜Q¨°¸LÐTXÑYÜ˜Q¨°¸LÐTXÑYÜ˜Q¨°¸LÐTXÑYð ô ¬ °3¸¸3ÀÓ(CÑDÐEñ€Fð×&Ñ&Ð8Ð&Ó(Ð8°°a©LÐ8¨LÑ8×8×8×8Ò8Ð(×8×8×8×8×8Õ8ˆ6×8×8×8Ñ8ˆ6×8×8Õ8Ð&×8×8Ó8Ð(×8×8Ó8¨L×8×8×8×8×8×8Õ8Ø×'Ñ'Ð3Ð'Ó)Ð3¨a°¨VÐ3¨VÑ3×3×3×3Ò3Ð)×3×3×3×3×3Õ3ˆ6×3×3×3Ñ3ˆ6×3×3Õ3Ð'×3×3Ó3Ð)×3×3Ó3¨V×3×3×3×3×3×3Ö3r)&Ú__doc__ÚbuiltinsrKÚ_pytest.assertion.rewriteÚ assertionÚrewriterIrFÚpathlibrÚtypingrÚpytestÚquber.agents.classifierrrÚquber.agents.grid_locatorrrÚ%quber.core.extractors.camelot.acquirer Úquber.core.extractors.dualrrErrÚ!quber.core.extractors.dual.modelsr rrÚstrÚintrÚMonkeyPatchr]rbr…rr)rrÚr¡s¥ðñ÷„ƒÝÝã çDßCÝBÝ>Ý<ßSÑSðCð˜sð¨cð¸$¸tÀC¹y¹/ðÐN^ôð3Àf×FXÑFXô3ð)Àf×FXÑFXô)ð<À&×BTÑBTð<Ð`dô<ó04r