L`j z dZddlmZddlZddlZddlZddlZddlZddlZddl Z ddl Z ddl m Z m Z ddl mZddlmZeej%j&Ze j*j-deeddlmZmZmZmZmZgdZgd Zd d d d ddddddddd Z d)dZ!d*dZ"d+dZ#d,dZ$d-dZ%d.dZ&d/dZ'd0dZ(d1dZ)d2d Z*d3d!Z+d4d"Z, d5d#Z-d3d$Z.d6d%Z/d7d&Z0d8d'Z1e2d(k(r e3e1y)9zPrepare and optionally conduct a local, human-only review pilot. Neo4j access in this file is one read-only MATCH query. The only writes are to the explicitly local review_pilot.db and the Markdown report. ) annotationsN)datetimetimezone)Path)Any)CURATOR_VERSIONNORMALIZATION_VERSIONdigest normalizesource_quality) ArchitecturezAgent-Solutions SolutionsRunbooksSystemstrukturzKI-Kursez 01-Kontextz 05-Ressourcen) approved_for_pilotrejectedneeds_more_context duplicate wrong_type wrong_subjectwrong_predicate wrong_objectwrong_modalitywrong_polarity wrong_timeinsufficient_evidencerrrrrrrrrrrr) arcdtspomnzecdtjtjj SN)rnowrutc isoformat//opt/struktur/knowledge-curator/review_pilot.pyr+r+%s << % / / 11r/c,|jdddS)N/r)split)paths r0arear6)s ::c1 a  r/cgd}g}|D]7}|jtj||tj9t t j d|D}td|D}td|D}||rdj|nd|rdn|rd nd t|xs|xr| d S) N)z\b\d{4}-\d{2}-\d{2}\bz\b\d{1,2}\.\d{1,2}\.\d{4}\buc\b(?:januar|februar|märz|april|mai|juni|juli|august|september|oktober|november|dezember)\s+\d{4}\bz+\b(?:seit|bis)\s+(?:dem?\s+)?[^,.;\n]{1,30}u7\b(?:zuvor|aktuell|künftig|historisch|gestern|heute)\b)flagsc3<K|]}|jywr*)strip.0xs r0 zextract_time..5s8Qqwwy8sc3HK|]}tjd|yw)z)\d{4}-\d{2}-\d{2}|\d{1,2}\.\d{1,2}\.\d{4}N)re fullmatchr;s r0r>zextract_time..6s`UV2<< LaP`s "c3@K|]}|jdvyw)>künftigheutezuvoraktuellgesternN)casefoldr;s r0r>zextract_time..7sg\]1::<#WWgsz; unknowng??g)extracted_time_textproposed_temporal_scopetime_confidencetime_needs_review) extendr@findall IGNORECASElistdictfromkeysanyjoinbool)textpatternsfoundpatternabsoluterelatives r0 extract_timer^-sLH EE RZZR]]CDE 8%88 9E`Z_``HgafggH#(;@tyy'7i&.sUT!%h&J53I\!K MMr/cP|jdxsdj}|j|dj}|r&t|dksj dsd|ddvryd vsd vry d |vsd vryd|vsdvrt j dst j drytfddDrdvsdvrdnd}d|dddfSdvsdvrytfd d!Dr"d"dt j d#rd$dd%fSddd%fStfd&d'Dr^tfd(d)Drd*}n&d+vrd,}nd-vrd.}nd/vsd0vrd1}n d2vsd3vrd}nd4}t j d5rd$nd}d6||dd7fSt j d8ry9y:);NrXr5)zfrage:z question:?)NNrIrIno_claim_or_questionwunschu ich möchte)NNrIrI wish_not_fact"zzitat:)KnowledgeClaimreportedpositiverIquoted_or_reported_claim businessplanz(?:version|[_ -]v)\s*\dz\bversion\s*\d)DocumentVersionNrjrIdocument_version_signalc3&K|]}|v ywr*r.r<r=lows r0r>zclassify..Js 18 )z wurde durch z wurde ersetztu zurückgerolltz rollbackz migriertz aktualisiertrollbackuzurückgerollt rolled_backfactual_historicalKnowledgeEventrjrIchange_event_signal verworfenuzurückgezogen)rh withdrawnrjrIwithdrawn_plan_signalc3&K|]}|v ywr*r.rps r0r>zclassify..Os f18 frr)zmuss z darf nichtpolicyzregel:z erfordert verbindlich KnowledgeRulez\b(nicht|kein|keine)\bnegativenormative_signalc3&K|]}|v ywr*r.rps r0r>zclassify..Qs i18 irr) zist zsind war zwurde uläuftaktiv verwendetu unterstützt bestätigtgeplantplantkönntestatusc3&K|]}|v ywr*r.rps r0r>zclassify..RsIAqCxIrr)rrzsoll sollteplannedrproposedgetestettestedr produktiv confirmedr historischfactual_currentz\b(nicht|kein|keine|nie)\brhstate_or_capability_signalz#\b(behauptet|vermutet|laut|notiz)\b)rhrirjrIreported_claim_signal)NNrIrIno_deterministic_signal)getr:rHlen startswithr@searchrU)rowrXr5modalitypolarityrqs @r0classifyr>s GGFO !r ( ( *D --/C v;   !D 3t9r>S^^4K%LPSW[\`]`WaPaG3-3.@ d{h#o^ 4 >S#8biiHbdg>hmomvmvxIKNnOX ~ $.#$59IS9P=Vj:yBWWWc-4\ fe ffBII>WY\4]jox{MM Mcmox{MM M ih ii I!HI IV_8 # *x 3 8 S K3$6; s]lc1>R8*h!#+H#!N:T^8Y@\\\ yy7=[ Fr/c|jdxsd}tj|jj }id|dd|dd|dd |jd xs|d |d d |jd d|jdd|dddddt t |ddddt |dt |dkDddd|ddddttdS) NrXr`source_document_import_keydocument_import_keysource_content_hash content_hashsource_chunk_key chunk_keysource_text_hash text_hash relative_pathr5heading chunk_index evidence_textevidence_start_offsetrevidence_end_offsetevidence_offset_basisanalyzed_chunk_textevidence_lengthevidence_truncatedfull_evidence_availableT evidence_hashextraction_rulereview_pilot_heuristic_v2extraction_rule_versionz kc-rules-v2)curator_versionnormalization_version) rhashlibsha256encode hexdigestminrrr )rrXhs r0evidencer_sc 776? bDt{{}%//1A < (#.C*D < !3~#6 <8JCP[L\ <  4 9 <;JCPVK < swwy) <,9#''-:P < T$3Z <*A! < "3s4y##6 < 9PQf < s4y < +?D C < &t < Q <!23N < &} <JY%: < z"build_candidate..sFai51Fs) rrr:rstemr4r r rr^r )rrrtyprrscoperulerXrrobjstqualitysignal confidencebody key_fieldskey_names ` r0build_candidaterosL+3C=(C8UD  GGFO !r ( ( *Dggi :DV$5$:$:G#1D[$688;C8J **T1 a # &C(VdEBB 8z#9: C CRVZ* 3NF63{+;SA 3CSUX 3 wt} 3&19 3>F 3 6 3#-x 39CX 3 i 3*;E 3 !, 31A' 3  3 -:4 3 BOPT 3 $ 3 !+D 3 BF$D-CB'+vPV 3sm 3 ,D1 3D(gy#vxOa[aE9.J"-!+@VXX[]HF:FGDN Kr/c|jd|jdDchc]}|d }}d|vr|jdyycc}w)Na~ CREATE TABLE IF NOT EXISTS review_runs ( run_id TEXT PRIMARY KEY, curator_version TEXT NOT NULL, normalization_version TEXT NOT NULL, started_at TEXT NOT NULL, completed_at TEXT, candidate_count INTEGER NOT NULL, reviewer TEXT NOT NULL, status TEXT NOT NULL ); CREATE TABLE IF NOT EXISTS review_candidates ( candidate_id TEXT PRIMARY KEY, run_id TEXT NOT NULL, candidate_type TEXT NOT NULL, candidate_json TEXT NOT NULL, source_chunk_key TEXT NOT NULL, evidence_hash TEXT NOT NULL, created_at TEXT NOT NULL, review_batch INTEGER ); CREATE TABLE IF NOT EXISTS review_decisions ( decision_id TEXT PRIMARY KEY, candidate_id TEXT NOT NULL, reviewer TEXT NOT NULL, decision TEXT NOT NULL, reason TEXT NOT NULL, corrected_candidate_json TEXT, reviewed_at TEXT NOT NULL, review_duration_seconds REAL ); CREATE TABLE IF NOT EXISTS review_audit ( audit_id TEXT PRIMARY KEY, candidate_id TEXT NOT NULL, previous_state TEXT NOT NULL, new_state TEXT NOT NULL, action TEXT NOT NULL, actor TEXT NOT NULL, reason TEXT NOT NULL, created_at TEXT NOT NULL ); z$PRAGMA table_info(review_candidates)r3 review_batchz=ALTER TABLE review_candidates ADD COLUMN review_batch INTEGER) executescriptexecute)dbrcolumnss r0schemarsX ,"$,R!ST#s1vTGTW$ RS%Us A c ddlm}|j|||f} |j5}|j dj d|j dj d|j dj d|j dj d|j d j d |j d j d d }|j d Dcgc] }t |}}dddf|jScc}w#1swY"xYw#|jwxYw)Nr GraphDatabaseauthz/MATCH (n:ObsidianDocument) RETURN count(n) AS nr&z,MATCH (n:ObsidianChunk) RETURN count(n) AS nz'MATCH (n:Episodic) RETURN count(n) AS nz%MATCH (n:Entity) RETURN count(n) AS nz7CALL db.labels() YIELD label RETURN collect(label) AS xr=z5SHOW CONSTRAINTS YIELD name RETURN collect(name) AS x) documentschunksepisodicentitylabels constraintsaOMATCH (d:ObsidianDocument)-[:HAS_CHUNK]->(c:ObsidianChunk) RETURN d.relative_path AS path,d.import_key AS document_import_key,d.content_hash AS content_hash, c.chunk_key AS chunk_key,c.chunk_index AS chunk_index,c.heading AS heading,c.text AS text,c.text_hash AS text_hash ORDER BY c.chunk_key)neo4jrdriversessionrunsinglerSclose) uriuserpasswordrrr" inventoryr=rowss r0 fetch_rowsrsD#  ! !#T8,< ! =F ^^  (UU#TU\\^_bc%% NOVVXY\]EE"KLSSUVYZ%% GHOOQRUV%% YZaacdgh uu%\]ddfgjk I&'UU,&&'(DG(D( ($  ( ( (  s5E CD? D:D? E :D??EE EcRddlm}|j|||f} |j5}|j d|Dcgc] }t |c}cddd|j Scc}w#1swYnxYw |j y#|j wxYw)NrrraMATCH (d:ObsidianDocument)-[:HAS_CHUNK]->(c:ObsidianChunk) WHERE c.chunk_key IN $keys RETURN d.relative_path AS path,d.import_key AS document_import_key,d.content_hash AS content_hash, c.chunk_key AS chunk_key,c.chunk_index AS chunk_index,c.heading AS heading,c.text AS text,c.text_hash AS text_hash ORDER BY d.import_key,c.chunk_index)keysrrrr r rSr )r rrrrrr"r=s r0fetch_source_rowsrs#  ! !#T8,< ! =F ^^  B%&UU,5<@ &+&ABDGB B B   B B B B   4BA6A1A6 B1A66A?;BB&c i}|D]n}|j|dt|jdd|t|jdd||jddfgj|p|D]x}ggg}}}|dt|jdd|t|jdd||jddf}||D]}|d|dk(rt|jdd|t|jdd|k(} |jd |jd k(} |jd |jd k(} | r| r| r|j|d|j|d|dd k7s| r)| r'|jd s|jd s| r|j|d||d <||d <||d<d|d<{y)Nrrr`rrrIrrrrrmpossible_duplicatespossible_similarpossible_conflictszsame type+normalized subject/predicate+authority; unknown time overlaps; object/polarity/modal difference is only a conflict candidate; DocumentVersion excludedcomparison_rule) setdefaultr rappend) candidatesrgroupsr duplicatessimilar conflictsckeyother same_object same_polarity same_modalitys r0comparison_metadatar)s2DFF y1-. !%% 2:NPU0V$QUU;%;UCQUUK\^gEhjkm oououvwoxyB)+RYG "#YquuY/CU%K!%% R0%8!%%@QS\:]_D\ %:; <$.  ' "+  B %Br/c tj|j} t||j dDcgc]}t j |d}}t|dk7rtdt||jr!|jrtjds tdt|j|jtjd|Dcgc]}|d c}}|Dcic]}|d| }}|D]`}|j|d}|s|j!t#||j!t%|jd xsd bt'|t j t)|j*j-d D cic]} | |Dcgc] }|d | k(s |c}} } }g} | j/| d dd| j/| ddd| j/| dddt1| dd} | j/| dd| Dchc]}|d } }|D]?}t| dk\rn/|d| vs| j3|| j5|dA| ddDchc]}|d c}|j d|D]?}|dvrdnd}||d<|j dt j6|d||dfA|j9gd}t;|Dcgc] }|dvs |c}dD]\}}|d|d|dd|d d d!|d"d#|d$d#|d%d&|jd'd(|jd)d d*|jd+d,|jd-d.|jd/d0|d1d2|dd3|jd4d d5|d6j=t?dd7d d8d9jA|jd:gxsd;dd g z }!t)|jBjEd?jA|d@AdBd dCd dDt|dEtdFd dGd g}t;|dD] \}}|dH|d|dd|d dI|jdJdK|jdd d!|d"d#|d$d#|d%d*|jd+dLd9jA|jdMgxsd;dN|jdOd dP|jd-dQ|jd/dR|d1d(|dd dSt|jd:gdTt|jd=gd gz }t)|jFjEd?jA|d@AtIt j6dt| Dcic]tKfdU|Dc}|j|jBdVddWX |jMycc}wcc}wcc}wcc}wcc}} wcc}wcc}wcc}wcc}w#|jMwxYw)YNzBSELECT candidate_json FROM review_candidates ORDER BY candidate_idr(z.Erwartet wurden 40 Pilotkandidaten, gefunden: NEO4J_PASSWORDuaFür Evidence-/Zeit-Reconciliation müssen NEO4J_URI, NEO4J_USER und NEO4J_PASSWORD gesetzt sein.rrrXr`)rhr~rvrmrrvr3rmr~rhcf|jdd t|jd |dfS)NrFrr)rrW)rs r0z&prepare_review_batch..sZaeeL`bgFhBhnrstsxsxzNtOoPkPRSTbRcBdr/)keyr z.UPDATE review_candidates SET review_batch=NULLrzQUPDATE review_candidates SET candidate_json=?,review_batch=? WHERE candidate_id=?F ensure_ascii)z# Review Batch 1r`Status: `prepared_unreviewed`r`zXNur lokale Reviewdaten; keine fachlichen Entscheidungen und keine Neo4j-Schreibfreigabe.r`z## . - Typ: `` - Aussage: r / rr- Modalität/Polarität: `r` / `rz - Zeit: `rLu`; Evidence-Länge: ru Zeichen; gekürzt: r - Quelle: `rz `; Chunk `z `; Heading `r - Evidence: `r u- mögliche Duplikate: , rkeineu- mögliche Konflikte: ru>- Offener Prüfpunkt: fachliche Entscheidung durch den Nutzer.rutf-8encodingu1# Knowledge-Curator Review-Pilot – aktualisiertr4z Kandidaten: z; Review-Batch 1: z); automatische Wahrheitsentscheidungen: 0u## Kandidatenübersicht### z `; Status: `rz`; review_batch: `z `; erkannt: `rKu`; Review nötig: `rNz - Evidence: u Zeichen; gekürzt: `z `; Quelle: `z - Duplikate: u; mögliche Konflikte: c3>K|]}|dvs |dk(yw)rrNr.)r<r chosen_idsr=s r0r>z'prepare_review_batch..$s+*uUVWeUfjtUt1-=+>!+C*us  )rselectedtypesrreportr3indent)'sqlite3connectrrrjsonloadsr SystemExitr rosgetenvrenvironrupdaterr^r)rr read_textrOsortedradddumpscommit enumeratereplacechrrV batch_report write_textrIprintsumr )argsrr=rr source_rowsr source_by_keysourcerby_typechosenclaimsusedbatchlinesifullrFs ` @r0prepare_review_batchrns3  !B=r *,**5y*z{Q 1Q4 {{ t9?McRVi[YZ Zxxtyy :J0KAB B'$))RZZHX=Y{\Avw\]^p\q\AB 4?@q;*@ @ ]A"&&q);'<=F&)*AHH\&**VBTBZXZ5[,\ ] D$**T$**-=-G-G-I"JKT\]C3DGqA.>,?3,FGG]] g./34 g/0!45 go.r23 018de fRaj!+12a.!22 \A6{b % ,fmmA.>>IZ@[ \28=Aa'=  CD VA>*j8AdE %An  JJj 1595!NBST V V q$RQ!N2Cz2QqRTUV \DAq A3b>!2 34CSAT@UUV6W#AiL>Q{^4DC( }U21553D2EU155Q[K\J]]^_!!%%(A"B!CCWXYX]X]^oXpWqrFGHGLGLMaGbFcd#Ao$6#7z!DVBWAXXdefejejkteudvvwx%a&8&@&@R#&N%OqQ/ !%%@UWY:Z0[0f_f/gh/ !%%@TVX:Y0Z0e^e/fgVXZ\ \E \ T  **499U+;g*NCRIhjls4yk);C O;LLuvxz)2/dA& ODAq tA3b>!2 34CSAT@UUabcbgbghybza{|NOPOTOTUcOdNeef7g"1Y<.AkN3C3q{mT '@!A B-PTPYPYZ[Z_Z_`uwyZzP{QG@GPHH[\]\a\abu\v[wwxy#AEE*;$<#==RSTSXSXYmSnRoo{|}N}O|PPUVWXjVkUllmn$S/Db)I%J$KKbcfghglglnBDFhGdHcIJLN O OD O T[[$$TYYt_w$G djj!Z-4$6()%&s*uT*u'u$u$6=AWWPTPaPacqv@AB C  w| \A@ H]3>S,$6  sZ9Z  BZ90 Z< Z9 ZZ92BZ9 Z ZZZ!A3Z9 Z% Z9?.Z9- Z*9A5Z9. Z/;Z/?K7Z96Z4&Z9 Z9ZZ99[ cRg}|D]%}t|d|}|s|j||f'tDcic]}|g}}|D]9}t|dd|vs|t|ddj|;g} t dD]Ct fd|Dd}|s| j|j |ddEtD]I} || s || dddvs|| d}| j|j |ddKt|D cgc]\} }| dzdk(s|ddvs|c}} D]:}t| |k\rn*| j|j |dd<|D]E}t| |k\rn5|ddvs| j|j |ddGt||t| tfd| Dt| D chc]} t| ddc} tD cgc]&}|| D chc]} t| ddc} vs%|(c} }d } | D cgc]} | d d | dizc} | fScc}wcc}} wcc} wcc} wcc} }wcc} w) N selectionrr5)rvr~rmrhc3PK|]}|ddk(s|ddvs|yw)r3rrrNr.)r<r#riwanteds r0r>z$select_population..8s7o1AaD1A,Bf,LQRSTQUVaQbjnQnQos & &&rc3,K|] }|vsd yw)r3Nr.)r<r# systematics r0r>z$select_population..IsCk![\`j[jACks )eligible_with_candidatetargetrGsystematic_selected areas_present areas_missingr3_row) rr AREA_NAMESr6setnextrXr[rrarW)rrrweligibler candidater=by_areapairrGnamerlr#methodrurirrs @@@r0select_populationr+sH.#Ce<  OOS), -.WaFaQRq"uFaGFaY Q G +WT$q'&/5J-K-R-RSW-XY<>H 5DZBooquv  OOD !488DGK,@#AB [ 4=WT]1-a0=TI4=#DX__T%:DHHT!W[EY x=F "EtxxQ (<=>B x=F "E 7; t + OOD !488DGK,@#AB*-X&h-CkxCk@k%8&LatAaDL'9&LM+5ia_gBhZ[4!V CUBh9hikF,4 4aAaDFAaD> ! 4f <<7Gbn'MBhi 4sA J 6J JJJ; JJJ"J0J$Jc`dDcic]tfd|D}}d|dddddddd|d d |d d |d d|ddt|d|dddj|dddj|dxsddddgd|jDdt|dddd}t |dD]o\} } | dj d d!} |d"| d#| d$d%| d&d'd(| d)d*| d+d*| d,d-| d.d/| d0d'd1| d2d3| d4d5| d6d7| dd8d'd9dgz }q|d:dg|Dcgc],}d;|d<d=|d>rd?nd@dA|dBdC|dDdE|dFdC|dG .c}zz }|j d j|d zdHIycc}wcc}w)JNrc3.K|] }|dk(ywrNr.r<rr=s r0r>zwrite_report..QsB!Q'(A-Bz!# Knowledge-Curator Review-Pilot r`r4uDDieser Bericht enthält Kandidaten, keine fachlichen Entscheidungen.z$## Population und Sicherheitsbestandz- ObsidianDocument: rz- ObsidianChunk: rz - Episodic: rz - Entity: ru- ausgewählte Kandidaten: z- systematische Stichprobe: rxz - Bereiche: r?ryz!- nicht vorhandene Zielbereiche: rzr@z## Typenc32K|]\}}d|d|yw)- : Nr.)r<kvs r0r>zwrite_report..[s HAA3b}Hsz- needs_review: z)- automatische Wahrheitsentscheidungen: 0z ## Kandidatenr3rrr>rDr5rr6rr7r8rr9rrr:rr;rr<ru ` · Chunk `ru ` · Index rr=ru7- Entscheidung: offen; fachliche Prüfung erforderlich.u## Kontrollfälleridrpassed bestandenfehlgeschlagenz ; erwartet= expected_typer2expected_modalityu, tatsächlich= actual_typeactual_modalityrArB)rarrVitemsr[r\r_) r5rrrrcontrolsr=countsrkrlrr(s ` r0 write_reportrOsG`aBzBBBaFa0 92?^`b SUW 3R#Ik$:#; <@QR[\dReQf>gIj12 3z)HBUAV5W*3z?*; <@\]cdy]z\{>|DIIf_&=>? @06/;R1S1^W^0_ `bd  "IH " J0 1 "4_ "ac " "! "E*a(m1 o  & &tS 1 D2a/01Xa@P>Q=RRS3T) ~S;0@AhK=Q.q}oU1Z=/QRS/ 23<BT@U?VVabcdqbrast!!DS'!,.gik m mm !2 &go*pbcBqwir8+Zj9kkvwxzIxJwKKLMNObMcLddstuvCtDsEEFGHIZG[F\+]*pppEOODIIe$t+gO>+a(*ps F&1F+cn|jr!|jrtjds t dt j t|jj}t|j|jtjd\}}dtjtjj!dz}t#||t%dt'd|j(\}}g}|D]@}|j+dd||d<t-||d |d |d <|j/|Bg} gd } | D]?\} } } }t1d | d\}}}}}| j/| | | |||||| k(xr||k(dAt|j2}|j4j7ddt9j:|} t=||j?d|t@tBtttE|ddf|D]D}|j?d|d ||d t jF|d|d |dtfF|jI|jKtMt|jN||||| tQt jF|d||tE|dDcic]tSfd|Dc}tU||jNdd ddy#|jKwxYwcc}w)Nr,uZFehlende Neo4j-Credentials: NEO4J_URI, NEO4J_USER und NEO4J_PASSWORD müssen gesetzt sein.z kc-review-z%Y%m%dT%H%M%SZ2r{rrrr) )no_claimuNur eine Überschrift.NN)questionuFrage: Läuft Dienst X?NN)quoteu#Zitat: "Dienst X läuft produktiv."rhri)negationu#Dienst X läuft nicht auf Server Y.rhr)wishu.Ich möchte, dass Dienst X später aktiv wird.NN)planzDas Team plant den Import.rhr) rejected_planzDer Plan wurde verworfen.rhry)rsu Der Dienst wurde zurückgerollt.rvrt) historicalzIm Mai 2026 war Dienst X aktiv.rhru)version_no_conflictz*Businessplan Version 3 wurde dokumentiert.rmNz control.md)r5rX)rrXrrrrrrT)parentsexist_okz0INSERT INTO review_runs VALUES (?,?,?,?,?,?,?,?) unassignedprepared_unreviewedzINSERT INTO review_candidates(candidate_id,run_id,candidate_type,candidate_json,source_chunk_key,evidence_hash,created_at,review_batch) VALUES (?,?,?,?,?,?,?,NULL)Fr2rrc3.K|] }|dk(ywrr.rs r0r>zrun_pilot..s0^a3C1D1I0^r) rread_only_neo4jrrpcandidate_countcandidate_types review_dbrIrrJrKr)+r rrRrSrQrOrPrrrVrrTrr+rr,strftimermaxrlimitpopr rrrparentmkdirrMrNrrrr rrYrZr rrIr`rastr)rbrrrrrGrritemr control_casescidrXrrrr_rdbpathrrr=s `r0 run_pilotris 88499BII6F,Guvv JJtDJJ'113 4E 499bjjAQ6RSOIt HLL6??@PQ QF(uc"c"djj>Q6RSHfJ  X%fd3E.FM]H^_^$  H M8Ek3T="33;\[_<`3a0 _aDsD=.?P[,;T#.-#?#hOWhDhj kk $'']F MMt4  B r  EP_(#%JWlHn o 3A JJ}@ABP@QSY)*DJJqu,MqQcOd)352 3 3   dkk"FIvz8T $**4i#)c*o3{*}./+,S0^S]0^-^*^*}#&v;$++Qf h "!  -.   *}s!BLL2L/cRddlm}|j|||f} |j5}|j d|Dcgc] }t |c}cddd|j Scc}w#1swYnxYw |j y#|j wxYw)NrrrzMATCH (d:ObsidianDocument)-[:HAS_CHUNK]->(c:ObsidianChunk) WHERE d.import_key=$import_key RETURN c.chunk_index AS chunk_index,c.heading AS heading,c.text AS text ORDER BY c.chunk_index) import_keyr)r rrrrrr"r=s r0fetch_document_contextrs#  ! !#T8,< ! =F ^^  A%&UU,(4>&+&@ADGA A A   A A A A   rc tj|}|rdnd}|jd|zdzj}t |dD]\}\}} t j | } tj} td|dt|d| d tt jd D cic]} | | j| c} d d tdtdjj} | dvr|r|rt!j"ds tdn| dk(rIt%||t j&d| dg}t|r|djdndxsdnbt)||t j&d| d}|D];}td|dd|jdd|jdxsd=tdjj} | dvr| dk(rn7| dk(s| st*j| | } | t,vr td td!j}td"jxsd#}d}| j/d$rtd%jxsd}t1tj| z d&}|jd't3|t5||| ||t5|f|jd(t3|| t5|d)| d*||t5f|j7 |j9ycc} w)+Nr`z AND review_batch=1zSELECT candidate_id,candidate_json FROM review_candidates WHERE candidate_id NOT IN (SELECT candidate_id FROM review_decisions)z ORDER BY candidate_idr3z [r2z] r)rrrrrrrKrLrMrNr rrrrrrrrrrrrrrFrJrKudBefehl: a/r/c/d/t/s/p/o/m/n/z/e Entscheidung, v Evidence, x Dokumentkontext, k überspringen, q Endez> >rr=r,u*Für v/x fehlen sichere Neo4j-Credentials.rrrrXzEvidence nicht gefunden.rz --- Chunk rz | rz --- qruUngültig; übersprungen.u Begründung: z Reviewer: unbekanntwrong_z*Korrigierte Kandidaten-JSON (leer=keine): z5INSERT INTO review_decisions VALUES (?,?,?,?,?,?,?,?)z1INSERT INTO review_audit VALUES (?,?,?,?,?,?,?,?)r human_review)rMrNrfetchallr[rOrPtime monotonicr`rrYrinputr:rHrRrSrrTrDECISION_CODES DECISIONSrroundr r+rZr )rshow_allr rr batch_clausernumberrrawrstartedrdecisionrecontextrreasonreviewer correcteddurations r0 review_clirsb  B!2' djj0}~!!QUU1X+~MR[\] ^ tu;$$&//1*$d"))4D*EBCS*3bjjAQ6RUVWiUjTklvay}}V,xOOIs4,+>'?O@"//R[beoq/BrOOFC/@(@$AOBBOOT^hklptLmLiMOENOO$c$9L2L.MON ==?D #D)) {{$tww-488TYYGG   J/W$XX T?r/__main__)returnr)r5rrr)rXrrdict[str, Any])rrrz,tuple[str | None, str | None, str, str, str])rrrr)rrrrrrrzdict[str, Any] | None)rzsqlite3.ConnectionrNone)r rrrrrrz+tuple[dict[str, Any], list[dict[str, Any]]]) r rrrrrrz list[str]rlist[dict[str, Any]])rrrrrr)rbzargparse.Namespacerr)rrrrrwrrz+tuple[list[dict[str, Any]], dict[str, Any]])r5rrrrrrrrrrrrr) r rrrrrrrrr) rrrrWr  str | Nonerrrr)rr)4__doc__ __future__rrrrOrRr@rMsysrrrpathlibrtypingr__file__resolverrr5insertrcuratorrr r r r r|rrr+r6r^rrrrrrr)rnrrrrrr__name__rQr.r/r0rs1 #  ' H~&&3t9%%K  X ,*CW"O(~DT'lAXZ 2!M"GB < @T8, B4?D!=H?1?=Q?VZ?45 p %P& zDF!33r/