iUdZddlZddlZddlmZmZddlmZddlmZddl m Z eje Z edZehdZeeed <Gd d Zy) uy core/workers/genesis_task_worker.py GenesisTaskWorker — converts AIVA's TASK_DISPATCH intent into a Genesis RWL task written to the Genesis task board at loop/tasks.json. Created by Story 5.09 (AIVA RLM Nexus PRD v2). Responsibilities: 1. Extract task description from intent.utterance + extracted_entities 2. Build a task entry with source="AIVA", status="pending", and a UUID 3. Append the entry to loop/tasks.json (load → append → write, no overwrite) 4. Return {"task_id": , "status": "queued"} — never None No SQLite. All file I/O is injected at construction so tests never touch the real task board. N)datetimetimezone)Path)uuid4)Anyz%/mnt/e/genesis-system/loop/tasks.json>you knowaheroksouhumjustlikeokaywellrightactually basically literally _FILLER_WORDSceZdZdZddedzddfdZdedefdZdede fdZ d e de fd Z de efd Z d e eddfd Zy)GenesisTaskWorkeray Converts an AIVA TASK_DISPATCH IntentSignal into a Genesis RWL task entry written to the task board JSON file. All file I/O goes through self._path so the worker is fully testable without touching the real loop/tasks.json. Args: task_board_path: Override the default TASK_BOARD_PATH (used in tests via ``tmp_path``). Ntask_board_pathreturnc"|xst|_yN)TASK_BOARD_PATH_path)selfrs 9/mnt/e/genesis-system/core/workers/genesis_task_worker.py__init__zGenesisTaskWorker.__init__=s*=o intentcKtt}|j|}||dtjt j jdd} |j}|j||j|tjd|||d d S#t$r/}tjd||dt|dcYd}~Sd}~wwxYww) u Main entry point. Called by SwarmRouter for every TASK_DISPATCH intent. Steps: 1. Build a human-readable task description from utterance + entities. 2. Create a task entry dict with a UUID, source="AIVA", created_at (ISO 8601 UTC), and status="pending". 3. Load existing tasks from the task board, append the new entry, and write the updated list back atomically. 4. Return {"task_id": , "status": "queued"}. Args: intent: An IntentSignal instance (duck-typed — no direct import keeps this worker decoupled from the classifier layer). Returns: dict with at minimum ``task_id`` and ``status`` keys. Never None. AIVApending)id descriptionsource created_atstatusz&AIVA task queued: id=%s description=%rz!Failed to write task to board: %serror)task_idr,reasonNqueued)r.r,)strr_build_task_descriptionrnowrutc isoformat _load_tasksappend _save_tasksloggerinfo Exceptionr-)r r$r.r) task_entrytasksexcs r!executezGenesisTaskWorker.executeDs&57|77? &",,x||4>>@   O$$&E LL $   U # KK8 #h77  O LLs r!r6zGenesisTaskWorker._load_tasksszz  "I jj**G*<BBDG ::g&D$% $%/)C!$((3-6#Cy() NNLdjj I$$g.  NNBDJJPS TI s5-C &C34C(C/"CD+"D DDr=c|jjjdd|jjt j |ddy)a  Write the tasks list back to the task board JSON file. Uses ``json.dumps`` with indent=2 for human-readable output. Creates parent directories if they don't exist. Args: tasks: Full list of task dicts to persist. T)parentsexist_ok)indentrUrVN)rparentmkdir write_textr[dumps)r r=s r!r8zGenesisTaskWorker._save_taskssC t< djjq9GLr#r)__name__ __module__ __qualname____doc__rr"rr_r?r1r2rHr^r6r8r#r!rr0s >t >t>+8C+8D+8b$c$c$<*#*#*""T$Z"H Md M Mr#r)rrr[loggingrrpathlibruuidrtypingr getLoggerror9r frozensetrr1__annotations__rrsr#r!r{sg$ '   8 $ >?!*! y~cMcMr#