Function cmd_task_memo

scripts/kanban_update.py:762–795

写入任务上下文记忆（跨 Agent 传递决策链）。 decisions: 逗号分隔的关键决策 warnings: 逗号分隔的风险提示

(task_id, agent_id, decisions, warnings='')

def cmd_task_memo(task_id, agent_id, decisions, warnings=''):
    """写入任务上下文记忆（跨 Agent 传递决策链）。

    decisions: 逗号分隔的关键决策
    warnings: 逗号分隔的风险提示
    """
    TASK_MEMORY_DIR.mkdir(parents=True, exist_ok=True)
    memo_file = TASK_MEMORY_DIR / f'{task_id}.json'

    decision_list = [d.strip() for d in decisions.split(',') if d.strip()]
    warning_list = [w.strip() for w in warnings.split(',') if w.strip()] if warnings else []

    # 从 tasks_source.json 获取当前状态
    tasks = atomic_json_read(TASKS_FILE, [])
    task = next((t for t in tasks if t.get('id') == task_id), None)
    phase = task.get('state', '') if task else ''

    chain_entry = {
        'agent': agent_id,
        'phase': phase,
        'key_decisions': decision_list,
        'warnings': warning_list,
        'at': now_iso(),
    }

    def modifier(data):
        if not data:
            data = {'task_id': task_id, 'context_chain': []}
        data.setdefault('context_chain', []).append(chain_entry)
        return data

    atomic_json_update(memo_file, modifier, {})
    log.info(f'📝 {task_id} 任务记忆: {agent_id} → {len(decision_list)} 决策')
    _append_audit(task_id, agent_id, 'task_memo', None, None, f'{len(decision_list)} decisions')


def cmd_shared_memo(content, added_by):