Xj(UdZddlmZddlZddlZddlZddlZddlZddlmZm Z ddl m Z e e jjjZedz dz ZdZd Zhd Zej(Zgad ed <d ad dZd!dZd!dZd"dZd#d$dZd%dZd&dZd'dZ d(dZ!d)dZ"d*dZ#d%dZ$d+d,dZ%d"dZ&d-d.dZ'd/dZ(d/dZ)d0d1dZ*y)2uDurable task ledger — the trail every background task leaves behind. WHY THIS EXISTS (2026-07-16, Ahmed's call): a background worker used to live only in RAM. If Jarvis crashed or restarted mid-task, the task — and any finding it had produced — vanished silently. And when Ahmed later asked "did you do X?" / "what happened to X?", the master had nothing durable to consult, so it either guessed or shrugged. Both are wrong. This ledger records EVERY dispatched task to disk the moment it starts, updates it tool-by-tool as it runs, and finalizes it on done/fail/kill — so: 1. RECOVERY — on boot, any task still marked "running" is stale (the process that owned it died); we relabel it "interrupted" so the trail shows exactly where things stopped. 2. RECALL — the master can query this ledger ("did you send that email?") and answer the TRUE state (done at 4:12 / still running / failed because the Gmail call errored / interrupted by a restart) instead of guessing. 3. CROSS-DEVICE MEMORY — on completion the pool also drops a milestone checkpoint into jarvis-memory (fire_save), so "what happened to X?" works days later from any device, not just this process's lifetime. Storage is a single JSON file (control/task-ledger.json) rewritten atomically on every change — the task volume is a handful per hour, so this is trivially cheap and dead simple to reason about. Kept to the last MAX_TASKS records. The module is self-contained: it imports nothing from the rest of the voice package at import time (memory_control is lazy-imported inside the checkpoint helper), so it can be used from the pool, the engine, or a plain thread. ) annotationsN)datetimetimezone)Pathcontrolztask-ledger.json>donefailedkilled interrupted list[dict]_tasksFchtjtjj dS)Nseconds)timespec)rnowrutc isoformat?/Users/ahmed/devFolder/Ultron/claude-voice/voice/task_ledger.py_nowr7s# << % / / / CCrcl tjjdtjd}|j t j tt dddtj|ty#t$r%}tdt|dd d Yd}~yd}~wwxYw) z0Write the ledger atomically. Caller holds _lock.T)exist_okz .json.tmpNFr) ensure_asciiindentz# [task-ledger: write failed: x])LEDGERparentmkdir with_suffix write_textjsondumpsr MAX_TASKSosreplace Exceptionprintstr)tmpes r_persist_lockedr/;sE T*  - tzz&)"5E)*, - 3 E 3CF4CL>CDDEsBB B3B..B3cxt5tr dddy tjrEt j tj xsd}t|tr |t da dadddy#t$r'}tdt|dddga Yd}~6d}~wwxYw#1swYyxYw)z9Read the ledger from disk into memory. Call once at boot.Nz[]z" [task-ledger: load failed: rrT)_lock_loadedr is_filer%loads read_text isinstancelistr'rr*r+r,)datar.s rloadr9Gs     ~~zz&"2"2"4"<=dD)!9*+.F   6s1vds|nAF GF  s5B0AA=2B0= B-B(#B0(B--B00B9cg}t5tD]G}|jddvsd|d<t|d<d|d<|j t |I|r t ddd|S#1swY|SxYw)zBoot recovery: any task still 'running'/'queued' from a PRIOR process can't be alive now (we just started), so mark it 'interrupted'. Returns the records that were interrupted so the caller can proactively tell Ahmed.status)runningqueuedr endedz1interrupted by a restart/crash before it finishederrorN)r1rgetrappenddictr/)r ts r recover_stalerDXs|!K AuuX"77+( !V' P' ""47+        sA0?A00A:cdtjjddz}|||xsdjdd|xsdjdd|dgddt t ddd }t 5t j|tt tkDrt dt =tddd|S#1swY|SxYw) zBRegister a freshly-dispatched task. Returns its durable ledger id.t_N r r<F) idworkertitletasktierr;stepsresultr?createdstartedr> checkpointed) uuiduuid4hexstriprr1rrAlenr'r/)rKrLrMrNtidrecs rcreater[is !!#2& &C+2$$&t,""$Tc*66 C  c v; "{ {#  J  Js 5ACC c\ttD]}|jd|k(s|cSy)NrJ)reversedrr@rYrCs r _find_lockedr_s+ f  55;# H rc|r|syt5t|}||jdtvr dddy|j dgj t |dddt|dtkDr|ddd|dtdz dz|d<|dd|d<tdddy#1swYyxYw)zBAppend a live tool-step note (what the worker is doing right now).Nr;rO)rCnote last_step) r1r_r@ _TERMINAL setdefaultrArrX MAX_STEPSr/)rYrbrCs rsteprhs d    9h94   Wb!((tvtDSz)JK qz?Y &7BQ!G*y1}5E5F*GGAgJds+ s&B6A2B66B?ct5t|}| dddyd|d<|xsdjdd|d<t|d<t t |cdddS#1swYyxYw)zIMark a task done with its result. Returns the record (for checkpointing).Nr r;rHirPr>r1r_rWrr/rB)rYrPrCs rfinishrksh    9 ( |**,Ud3( V' Aw A)AA))A2ct5t|}| dddyd|d<|xsdjdd|d<t|d<t t |cdddS#1swYyxYw)z7Mark a task failed with the reason. Returns the record.Nr r;rHrIr?r>rj)rYr?rCs rfailrnsh    9 ( kr((*4C0' V' Aw rlc(ddddddj||}t5t|}||jdtvr dddy||d<t |d<|dk(rd |d <n |dk(rd |d <t dddy#1swYyxYw) uSet a NON-result terminal status (killed/interrupted). Never downgrades a task that already finished (done/failed) — those keep their real outcome. Accepts the pool's status words and normalizes them.r r r r )r stoppedr completedr Nr;r>zkilled on requestr?zinterrupted before it finished)r@r1r_rerr/)rYr;normrCs rmarkrss=(v #FF 3     9h94  ( V' 8 ,AgJ ] "9AgJ s&B1BBcrt5t|}|d|d<tdddy#1swYyxYw)NTrS)r1r_r/r^s rmark_checkpointedrus.    = $An    s-6cnt5t|}|r t|ndcdddS#1swYyxYw)N)r1r_rBr^s rr@r@s$   tAw s+4ct5t| dDcgc] }t|c}dddcdddScc}w#1swYyxYw)N)r1rrB)nrCs rrecentrzs> !'-AQ-dd3 - s =8==Act5tDcgc]"}|jddk(st|$c}dddcdddScc}w#1swYyxYw)Nr;r<rx)r1rr@rB)rCs r open_tasksr|sE !'HA155?i+GQH2N H s AA  A A AAc|xsdjj}t5tt}ddd|s#| dDcgc] }t |c}dddSg}t D]}dj|jdd|jdd|jdd|jdddjd |jd gDgj}||vr|jt |t||k\s|S|S#1swYxYwcc}w) z|Case-insensitive substring search over title/task/result/steps, newest first. Empty query returns the most recent tasks.rHNrx rLrMrPr?c3@K|]}|jddyw)rbrHN)r@).0ss r zfind..sC0B1QUU62&0BsrO) rWlowerr1r7rrBr]joinr@rArX)querylimitqpoolrChitshays rfindrs" "##%A F|  !%ufg/AQ/"55 D d^hh EE'2 fb 115523F EE'2  HHCgr0BC C   57 8 KKQ t9   K K 0sD3 D?3D<c tj|jdxs|jd}|jdrtj|dn"tjtj }t ||z j}|dk\r|dzd|dzddS|dS#t$rYywxYw) NrRrQr><m02dr?) r fromisoformatr@rrrint total_secondsr*)rZstartendrs r_agers&&swwy'9'OSWWY=OP7:www7Gx%%c'l3LL. u++- .-."W!r'!AF3rRrHNTr~r rPrrfinished'u ' — DONE (z, ended z): r<u' — STILL RUNNING (z so far; last step: rdu…)r u' — FAILED (r?z unknown errorr u' — KILLED on request (r u1' — INTERRUPTED by a restart before finishing (u' — )r@r)rW splitlinesr)rZstrLwhenbodys r summarizersq 3 B GGGV $E GGG  8 2 8b#2 > F FsC PD V|FIgghFWswwx$**,779!. s7$QTIaL($s)rr)rrrs r recall_textrsN U #D 6).VE7"%9 :479 : 997$7 77r)returnr,)rNone)rr)rK) rKr,rLr,rMr,rNr,rr,)rYr,r dict | None)rYr,rbr,rr)rYr,rPr,rr)rYr,r?r,rr)rYr,r;r,rr)rYr,rr) )ryrrr))rr,rrrr)rZrBrr,)rHr)rr,rrrr,)+__doc__ __future__rr%r( threadingtimerTrrpathlibr__file__resolver!PROJECTr r'rgreLockr1r__annotations__r2rr/r9rDr[r_rhrkrnrsrur@rzr|rrrrrrrrs<#  ' x. " ) ) 0 0 9 1 1    8    D E""6   (& 4 O ,!(8r