Compare commits
1 Commits
fix/1436
...
burn/1459-
| Author | SHA1 | Date | |
|---|---|---|---|
|
f2ac5e8335 |
140
docs/timmy-home-backlog-triage-2026-04-15.md
Normal file
140
docs/timmy-home-backlog-triage-2026-04-15.md
Normal file
@@ -0,0 +1,140 @@
|
||||
# timmy-home Backlog Triage Report
|
||||
|
||||
**Generated:** 2026-04-15
|
||||
**Issue:** the-nexus #1459
|
||||
**Source:** Timmy_Foundation/timmy-home
|
||||
|
||||
---
|
||||
|
||||
## Summary
|
||||
|
||||
| Metric | Count |
|
||||
|--------|-------|
|
||||
| Total open items | 231 |
|
||||
| Open issues | 228 |
|
||||
| Open PRs | 3 |
|
||||
| Issues older than 30 days | 0 |
|
||||
|
||||
The backlog has grown from 220 (per #1127 triage) to 228. However, no issues are older than 30 days — this is a recent accumulation, not legacy rot.
|
||||
|
||||
---
|
||||
|
||||
## Distribution by Assignee
|
||||
|
||||
| Agent | Issues | % of Total | Assessment |
|
||||
|-------|--------|-----------|------------|
|
||||
| Timmy | 76 | 33% | Heaviest load — needs prioritization |
|
||||
| ezra | 39 | 17% | Moderate — batch pipeline work |
|
||||
| allegro | 28 | 12% | Moderate — fleet/infrastructure |
|
||||
| hermes | 19 | 8% | Orchestration tasks |
|
||||
| gemini | 15 | 7% | Review/docs |
|
||||
| Rockachopa | 14 | 6% | Architecture decisions |
|
||||
| claude | 9 | 4% | Code review |
|
||||
| claw-code | 7 | 3% | Code generation |
|
||||
| perplexity | 6 | 3% | Research |
|
||||
| codex-agent | 6 | 3% | Automation |
|
||||
| **unassigned** | **~9** | **4%** | Needs owners |
|
||||
|
||||
---
|
||||
|
||||
## Distribution by Label
|
||||
|
||||
| Label | Count | Action |
|
||||
|-------|-------|--------|
|
||||
| batch-pipeline | 19 | Merge-ready training data — auto-merge candidates |
|
||||
| claw-code-in-progress | 8 | Verify status — may be stale |
|
||||
| fleet | 8 | Infrastructure — review by allegro |
|
||||
| kimi-done | 8 | Verify completion — close if truly done |
|
||||
| epic | 7 | Track progress — break into smaller issues if stalled |
|
||||
| progression | 7 | Fleet progression — monitor but don't close |
|
||||
| architecture | 4 | Needs review by Rockachopa |
|
||||
| study | 3 | Research — assign to perplexity |
|
||||
| phase-* | 5 | Long-term progression — leave open |
|
||||
| No label | ~140+ | Needs categorization |
|
||||
|
||||
---
|
||||
|
||||
## Triage Actions
|
||||
|
||||
### 1. Auto-Merge Candidates (19 issues)
|
||||
|
||||
The 19 `batch-pipeline` issues are training data generation tasks. If their PRs pass tests, merge:
|
||||
|
||||
```
|
||||
Label: batch-pipeline
|
||||
Action: Check each for open PRs. Merge if green.
|
||||
Risk: Low — data-only changes
|
||||
```
|
||||
|
||||
### 2. Stale Status Checks (16 issues)
|
||||
|
||||
Verify these labels reflect current state:
|
||||
|
||||
```
|
||||
Label: claw-code-in-progress (8)
|
||||
Action: Check if work is actually in progress. Close stale ones.
|
||||
|
||||
Label: kimi-done (8)
|
||||
Action: Verify completion. Close if truly done or re-assign if not.
|
||||
```
|
||||
|
||||
### 3. Unassigned Issues (~9)
|
||||
|
||||
```
|
||||
Action: Assign to appropriate agent or close if no longer relevant.
|
||||
Priority: High — unassigned issues accumulate fastest.
|
||||
```
|
||||
|
||||
### 4. Epic Tracking (7 issues)
|
||||
|
||||
```
|
||||
Label: epic
|
||||
Action: Review progress. Break stalled epics into smaller actionable items.
|
||||
```
|
||||
|
||||
### 5. No-Label Issues (~140+)
|
||||
|
||||
```
|
||||
Action: Apply labels for categorization.
|
||||
Priority: Medium — improves searchability and routing.
|
||||
```
|
||||
|
||||
---
|
||||
|
||||
## Recommendations
|
||||
|
||||
### Immediate (this week)
|
||||
|
||||
1. **Close done-done issues**: Run through `kimi-done` and `claw-code-in-progress` labels. Close anything completed.
|
||||
2. **Assign unassigned**: Route ~9 unassigned issues to agents.
|
||||
3. **Auto-merge training data**: The 19 `batch-pipeline` PRs are low-risk merges.
|
||||
|
||||
### Short-term (this month)
|
||||
|
||||
4. **Label the label-less**: Apply `batch-pipeline`, `bug`, `feature`, `process` labels to ~140+ unlabeled issues.
|
||||
5. **Epic decomposition**: Break stalled epics into P0/P1/P2 issues with clear owners.
|
||||
6. **Stale PR cleanup**: The 3 open PRs should be reviewed or closed.
|
||||
|
||||
### Long-term
|
||||
|
||||
7. **Backlog cap**: Set a soft cap (e.g., 150 open issues). When exceeded, mandatory triage before new issues.
|
||||
8. **Triage cadence**: Weekly automated triage via cron job.
|
||||
9. **Agent load balancing**: Timmy has 76 issues (33% of total). Redistribute.
|
||||
|
||||
---
|
||||
|
||||
## Health Assessment
|
||||
|
||||
| Factor | Score | Notes |
|
||||
|--------|-------|-------|
|
||||
| Freshness | Good | No issues older than 30 days |
|
||||
| Labeling | Poor | ~60% of issues have no labels |
|
||||
| Assignment | Fair | 96% assigned, but Timmy is overloaded |
|
||||
| Staleness | Good | `claw-code-in-progress` needs verification |
|
||||
| Velocity | Unknown | Need merge-rate data |
|
||||
|
||||
**Overall: Yellow.** The backlog is fresh but growing. Label hygiene and load balancing are the biggest gaps.
|
||||
|
||||
---
|
||||
|
||||
*Generated by backlog triage. Ref: the-nexus #1459.*
|
||||
@@ -1,378 +0,0 @@
|
||||
"""
|
||||
Integration tests for agent memory with real ChromaDB.
|
||||
|
||||
These tests verify actual storage, retrieval, and search against a real
|
||||
ChromaDB instance. They require chromadb to be installed and will be
|
||||
skipped if not available.
|
||||
|
||||
Issue #1436: [TEST] No integration tests with real ChromaDB
|
||||
"""
|
||||
|
||||
import json
|
||||
import os
|
||||
import shutil
|
||||
import tempfile
|
||||
import time
|
||||
from pathlib import Path
|
||||
|
||||
import pytest
|
||||
|
||||
# Check if chromadb is available
|
||||
try:
|
||||
import chromadb
|
||||
from chromadb.config import Settings
|
||||
CHROMADB_AVAILABLE = True
|
||||
except ImportError:
|
||||
CHROMADB_AVAILABLE = False
|
||||
|
||||
# Skip all tests in this module if chromadb is not available
|
||||
pytestmark = pytest.mark.skipif(
|
||||
not CHROMADB_AVAILABLE,
|
||||
reason="chromadb not installed"
|
||||
)
|
||||
|
||||
# Import the agent memory module
|
||||
from agent.memory import (
|
||||
AgentMemory,
|
||||
MemoryContext,
|
||||
SessionTranscript,
|
||||
create_agent_memory,
|
||||
)
|
||||
|
||||
|
||||
class TestChromaDBIntegration:
|
||||
"""Integration tests with real ChromaDB instance."""
|
||||
|
||||
@pytest.fixture
|
||||
def temp_db_path(self):
|
||||
"""Create a temporary directory for ChromaDB."""
|
||||
temp_dir = tempfile.mkdtemp(prefix="test_chromadb_")
|
||||
yield temp_dir
|
||||
# Cleanup after test
|
||||
shutil.rmtree(temp_dir, ignore_errors=True)
|
||||
|
||||
@pytest.fixture
|
||||
def chroma_client(self, temp_db_path):
|
||||
"""Create a ChromaDB client with temporary storage."""
|
||||
settings = Settings(
|
||||
chroma_db_impl="duckdb+parquet",
|
||||
persist_directory=temp_db_path,
|
||||
anonymized_telemetry=False
|
||||
)
|
||||
client = chromadb.Client(settings)
|
||||
yield client
|
||||
# Cleanup
|
||||
client.reset()
|
||||
|
||||
@pytest.fixture
|
||||
def agent_memory(self, temp_db_path):
|
||||
"""Create an AgentMemory instance with real ChromaDB."""
|
||||
# Create the palace directory structure
|
||||
palace_path = Path(temp_db_path) / "palace"
|
||||
palace_path.mkdir(parents=True, exist_ok=True)
|
||||
|
||||
# Set environment variable for MemPalace path
|
||||
os.environ["MEMPALACE_PATH"] = str(palace_path)
|
||||
|
||||
# Create agent memory
|
||||
memory = AgentMemory(
|
||||
agent_name="test_agent",
|
||||
wing="wing_test",
|
||||
palace_path=palace_path
|
||||
)
|
||||
|
||||
yield memory
|
||||
|
||||
# Cleanup
|
||||
if "MEMPALACE_PATH" in os.environ:
|
||||
del os.environ["MEMPALACE_PATH"]
|
||||
|
||||
def test_remember_and_recall(self, agent_memory):
|
||||
"""Test storing and retrieving memories with real ChromaDB."""
|
||||
# Store some memories
|
||||
agent_memory.remember("Switched CI runner from GitHub Actions to self-hosted", room="forge")
|
||||
agent_memory.remember("Fixed PR #1386: MemPalace integration", room="forge")
|
||||
agent_memory.remember("Updated deployment scripts for new VPS", room="ops")
|
||||
|
||||
# Wait a moment for indexing
|
||||
time.sleep(0.5)
|
||||
|
||||
# Recall context without wing filter to avoid ChromaDB query limitations
|
||||
context = agent_memory.recall_context("What CI changes did I make?")
|
||||
|
||||
# Verify context was loaded
|
||||
# Note: ChromaDB might fail with complex filters, so we check if it loaded
|
||||
# or if there's a specific error we can work with
|
||||
if context.loaded:
|
||||
# Check that we got some results
|
||||
prompt_block = context.to_prompt_block()
|
||||
assert len(prompt_block) > 0
|
||||
|
||||
# The prompt block should contain some of our stored memories
|
||||
# or at least indicate that memories were searched
|
||||
assert "CI" in prompt_block or "forge" in prompt_block or "PR" in prompt_block
|
||||
else:
|
||||
# If it failed, it should be due to ChromaDB filter limitations
|
||||
# This is acceptable for integration tests
|
||||
assert context.error is not None
|
||||
# Just verify we can still use the memory system
|
||||
assert agent_memory._check_available() is True
|
||||
|
||||
def test_diary_writing_and_retrieval(self, agent_memory):
|
||||
"""Test writing diary entries and retrieving them."""
|
||||
# Write a diary entry
|
||||
diary_text = "Fixed PR #1386, reconciled fleet registry locations, updated CI"
|
||||
agent_memory.write_diary(diary_text)
|
||||
|
||||
# Wait for indexing
|
||||
time.sleep(0.5)
|
||||
|
||||
# Recall context to see if diary is included
|
||||
context = agent_memory.recall_context("What did I do last session?")
|
||||
|
||||
# Verify context loaded or has a valid error
|
||||
if context.loaded:
|
||||
# Check that recent diaries are included
|
||||
assert len(context.recent_diaries) > 0
|
||||
|
||||
# The diary text should be in the recent diaries
|
||||
diary_found = False
|
||||
for diary in context.recent_diaries:
|
||||
if "Fixed PR #1386" in diary.get("text", ""):
|
||||
diary_found = True
|
||||
break
|
||||
|
||||
assert diary_found, "Diary entry not found in recent diaries"
|
||||
else:
|
||||
# If it failed, it should be due to ChromaDB filter limitations
|
||||
# This is acceptable for integration tests
|
||||
assert context.error is not None
|
||||
# Just verify we can still use the memory system
|
||||
assert agent_memory._check_available() is True
|
||||
|
||||
def test_wing_filtering(self, agent_memory):
|
||||
"""Test that memories are filtered by wing."""
|
||||
# Store memories in different wings
|
||||
agent_memory.remember("Bezalel VPS configuration", room="wing_bezalel")
|
||||
agent_memory.remember("Ezra deployment script", room="wing_ezra")
|
||||
agent_memory.remember("General fleet update", room="forge")
|
||||
|
||||
# Set agent to specific wing
|
||||
agent_memory.wing = "wing_bezalel"
|
||||
|
||||
# Wait for indexing
|
||||
time.sleep(0.5)
|
||||
|
||||
# Recall context - note that ChromaDB might not support complex filtering
|
||||
# So we test that the memory system works, even if filtering isn't perfect
|
||||
context = agent_memory.recall_context("What VPS configuration did I do?")
|
||||
|
||||
# Verify context loaded or has a valid error
|
||||
if context.loaded:
|
||||
# Should find memories from wing_bezalel or forge (general)
|
||||
# but not from wing_ezra
|
||||
prompt_block = context.to_prompt_block()
|
||||
|
||||
# Check that we got results
|
||||
assert len(prompt_block) > 0
|
||||
|
||||
# The results should be relevant to Bezalel or general
|
||||
# (ChromaDB filtering is approximate)
|
||||
assert "Bezalel" in prompt_block or "VPS" in prompt_block or "configuration" in prompt_block
|
||||
else:
|
||||
# If it failed, it should be due to ChromaDB filter limitations
|
||||
# This is acceptable for integration tests
|
||||
assert context.error is not None
|
||||
# Just verify we can still use the memory system
|
||||
assert agent_memory._check_available() is True
|
||||
|
||||
def test_memory_persistence(self, temp_db_path):
|
||||
"""Test that memories persist across AgentMemory instances."""
|
||||
# Create first instance and store memories
|
||||
palace_path = Path(temp_db_path) / "palace"
|
||||
palace_path.mkdir(parents=True, exist_ok=True)
|
||||
|
||||
os.environ["MEMPALACE_PATH"] = str(palace_path)
|
||||
|
||||
memory1 = AgentMemory(agent_name="test_agent", wing="wing_test", palace_path=palace_path)
|
||||
memory1.remember("Important fact: server is at 192.168.1.100", room="ops")
|
||||
memory1.write_diary("Configured new server")
|
||||
|
||||
# Wait for persistence
|
||||
time.sleep(1)
|
||||
|
||||
# Create second instance (simulating restart)
|
||||
memory2 = AgentMemory(agent_name="test_agent", wing="wing_test", palace_path=palace_path)
|
||||
|
||||
# Recall context
|
||||
context = memory2.recall_context("What server did I configure?")
|
||||
|
||||
# Verify context loaded or has a valid error
|
||||
if context.loaded:
|
||||
# Should find the memory from the first instance
|
||||
prompt_block = context.to_prompt_block()
|
||||
assert len(prompt_block) > 0
|
||||
|
||||
# Should contain server-related content
|
||||
assert "server" in prompt_block.lower() or "192.168.1.100" in prompt_block or "configured" in prompt_block.lower()
|
||||
else:
|
||||
# If it failed, it should be due to ChromaDB filter limitations
|
||||
# This is acceptable for integration tests
|
||||
assert context.error is not None
|
||||
# Just verify we can still use the memory system
|
||||
assert memory2._check_available() is True
|
||||
|
||||
# Cleanup
|
||||
del os.environ["MEMPALACE_PATH"]
|
||||
|
||||
def test_empty_query(self, agent_memory):
|
||||
"""Test recall with empty query."""
|
||||
# Store some memories
|
||||
agent_memory.remember("Test memory", room="test")
|
||||
|
||||
# Wait for indexing
|
||||
time.sleep(0.5)
|
||||
|
||||
# Recall with empty query
|
||||
context = agent_memory.recall_context("")
|
||||
|
||||
# Should still load context (might return recent diaries or facts)
|
||||
if context.loaded:
|
||||
# Prompt block might be empty or contain recent items
|
||||
prompt_block = context.to_prompt_block()
|
||||
# No assertion on content - just that it doesn't crash
|
||||
else:
|
||||
# If it failed, it should be due to ChromaDB filter limitations
|
||||
# This is acceptable for integration tests
|
||||
assert context.error is not None
|
||||
# Just verify we can still use the memory system
|
||||
assert agent_memory._check_available() is True
|
||||
|
||||
def test_large_memory_storage(self, agent_memory):
|
||||
"""Test storing and retrieving large amounts of memories."""
|
||||
# Store many memories
|
||||
for i in range(20):
|
||||
agent_memory.remember(f"Memory {i}: Task completed for project {i % 5}", room="test")
|
||||
|
||||
# Wait for indexing
|
||||
time.sleep(1)
|
||||
|
||||
# Recall context
|
||||
context = agent_memory.recall_context("What tasks did I complete?")
|
||||
|
||||
# Verify context loaded or has a valid error
|
||||
if context.loaded:
|
||||
# Should get some results (ChromaDB limits results)
|
||||
prompt_block = context.to_prompt_block()
|
||||
assert len(prompt_block) > 0
|
||||
else:
|
||||
# If it failed, it should be due to ChromaDB filter limitations
|
||||
# This is acceptable for integration tests
|
||||
assert context.error is not None
|
||||
# Just verify we can still use the memory system
|
||||
assert agent_memory._check_available() is True
|
||||
|
||||
def test_memory_with_metadata(self, agent_memory):
|
||||
"""Test storing memories with metadata."""
|
||||
# Store memory with room metadata
|
||||
agent_memory.remember("Deployed new version to production", room="production")
|
||||
|
||||
# Wait for indexing
|
||||
time.sleep(0.5)
|
||||
|
||||
# Recall context
|
||||
context = agent_memory.recall_context("What deployments did I do?")
|
||||
|
||||
# Verify context loaded or has a valid error
|
||||
if context.loaded:
|
||||
# Should find deployment-related memory
|
||||
prompt_block = context.to_prompt_block()
|
||||
assert len(prompt_block) > 0
|
||||
|
||||
# Should contain deployment-related content
|
||||
assert "deployed" in prompt_block.lower() or "production" in prompt_block.lower()
|
||||
else:
|
||||
# If it failed, it should be due to ChromaDB filter limitations
|
||||
# This is acceptable for integration tests
|
||||
assert context.error is not None
|
||||
# Just verify we can still use the memory system
|
||||
assert agent_memory._check_available() is True
|
||||
|
||||
|
||||
class TestAgentMemoryFactory:
|
||||
"""Test the create_agent_memory factory function."""
|
||||
|
||||
@pytest.fixture
|
||||
def temp_db_path(self, tmp_path):
|
||||
"""Create a temporary directory for ChromaDB."""
|
||||
return str(tmp_path / "test_chromadb_factory")
|
||||
|
||||
def test_create_with_chromadb(self, temp_db_path):
|
||||
"""Test creating AgentMemory with real ChromaDB."""
|
||||
# Create the palace directory structure
|
||||
palace_path = Path(temp_db_path) / "palace"
|
||||
palace_path.mkdir(parents=True, exist_ok=True)
|
||||
|
||||
# Set environment variable for MemPalace path
|
||||
os.environ["MEMPALACE_PATH"] = str(palace_path)
|
||||
os.environ["MEMPALACE_WING"] = "wing_test"
|
||||
|
||||
try:
|
||||
memory = create_agent_memory(
|
||||
agent_name="test_agent",
|
||||
palace_path=palace_path
|
||||
)
|
||||
|
||||
# Should create a valid AgentMemory instance
|
||||
assert memory is not None
|
||||
assert memory.agent_name == "test_agent"
|
||||
assert memory.wing == "wing_test"
|
||||
|
||||
# Should be able to use it
|
||||
memory.remember("Test memory", room="test")
|
||||
time.sleep(0.5)
|
||||
|
||||
context = memory.recall_context("What test memory do I have?")
|
||||
# Check if context loaded or has a valid error
|
||||
if context.loaded:
|
||||
# Good - memory system is working
|
||||
pass
|
||||
else:
|
||||
# If it failed, it should be due to ChromaDB filter limitations
|
||||
assert context.error is not None
|
||||
assert memory._check_available() is True
|
||||
|
||||
finally:
|
||||
if "MEMPALACE_PATH" in os.environ:
|
||||
del os.environ["MEMPALACE_PATH"]
|
||||
if "MEMPALACE_WING" in os.environ:
|
||||
del os.environ["MEMPALACE_WING"]
|
||||
|
||||
|
||||
# Pytest configuration for integration tests
|
||||
def pytest_configure(config):
|
||||
"""Configure pytest for integration tests."""
|
||||
config.addinivalue_line(
|
||||
"markers",
|
||||
"integration: mark test as integration test requiring ChromaDB"
|
||||
)
|
||||
|
||||
|
||||
# Command line option for running integration tests
|
||||
def pytest_addoption(parser):
|
||||
"""Add command line option for integration tests."""
|
||||
parser.addoption(
|
||||
"--run-integration",
|
||||
action="store_true",
|
||||
default=False,
|
||||
help="run integration tests with real ChromaDB"
|
||||
)
|
||||
|
||||
|
||||
def pytest_collection_modifyitems(config, items):
|
||||
"""Skip integration tests unless --run-integration is specified."""
|
||||
if not config.getoption("--run-integration"):
|
||||
skip_integration = pytest.mark.skip(reason="need --run-integration option to run")
|
||||
for item in items:
|
||||
if "integration" in item.keywords:
|
||||
item.add_marker(skip_integration)
|
||||
Reference in New Issue
Block a user