Multi-agent teams: parallel processing, agent-to-agent communication, and request tracking #163

Closed

dpbmaverick98 wants to merge 33 commits intoTinyAGI:mainfrom

dpbmaverick98:sql-experiment

Commits on Mar 5, 2026

feat(db): add conversation persistence tables and functions
Kimi Claw
committed
feat(queue-processor): implement parallel processing and restart recovery
Kimi Claw
committed
feat(signals): implement push notifications to replace HTTP polling
Kimi Claw
committed
fix(logging, queue-processor): add await to emitEvent for event ordering guarantee
Kimi Claw
committed
feat(db): add exponential backoff with jitter to message retry logic
Kimi Claw
committed
feat(heartbeat): add heartbeat monitoring for crash detection
Kimi Claw
committed
feat(queue-processor): add message size validation before invokeAgent
Kimi Claw
committed
fix(queue-processor): serialize inter-agent team conversation updates with conversation lock

authored and
Devain Pal Bansal
committed
fix(signals): handle race condition in signal cleanup with proper error handling

authored and
Devain Pal Bansal
committed
feat(db, queue-processor): add stale conversation recovery for crash resilience

authored and
Devain Pal Bansal
committed
fix(db): improve stale conversation recovery with better pruning and documentation

authored and
Devain Pal Bansal
committed
fix(db, queue-processor): reduce crash detection threshold and add recovery visibility
Kimi Claw
committed
feat: add database backup strategy and integrity checks (Gap 3)
Kimi Claw
committed
feat(db): add outstanding_requests table for agent handoff tracking
Kimi Claw
committed
feat(conversation): integrate outstanding request tracking into agent handoffs
Kimi Claw
committed
feat(queue-processor): add request timeout checker and ACK handling
Kimi Claw
committed
fix(queue-processor): complete outstanding request when agent responds
Kimi Claw
committed
fix(queue-processor): remove duplicate routing log line
Kimi Claw
committed
fix(db): remove deadline checks from acknowledgeRequest and respondToRequest
Kimi Claw
committed
fix(queue-processor, db): handle multiple outstanding requests to same agent
Kimi Claw
committed
feat(queue-processor, db): add missing maintenance and faster timeout checks
Kimi Claw
committed
docs: add comprehensive agent communication protocol documentation
Kimi Claw
committed
fix(queue-processor): await chain_step_start emitEvent for visualizer ordering
Kimi Claw
committed
feat(queue-processor): mark requests as failed when agent errors
Kimi Claw
committed
chore(queue-processor): remove unused import and fix prune interval
Kimi Claw
committed
docs: update agent communication protocol with final changes
Kimi Claw
committed

Commits on Mar 6, 2026

fix(installer): point remote-install to sql-experiment branch

authored and
Devain Pal Bansal
committed
fix(comms): route agent-to-agent responses back to sender

authored and
Devain Pal Bansal
committed
fix(events): emit chain_step_done event after agent completes

authored and
Devain Pal Bansal
committed
fix(install): point remote installer at official repo

authored and
Devain Pal Bansal
committed
fix(events): add .catch() to unawaited emitEvent calls

authored and
Devain Pal Bansal
committed
fix(backup): use atomic sqlite3 .backup instead of sequential cp

authored and
Devain Pal Bansal
committed
fix(db): align max_retries schema default with insert value

authored and
Devain Pal Bansal
committed

Provide feedback

Saved searches

Use saved searches to filter your results more quickly

Multi-agent teams: parallel processing, agent-to-agent communication, and request tracking #163

Multi-agent teams: parallel processing, agent-to-agent communication, and request tracking #163
dpbmaverick98 wants to merge 33 commits intoTinyAGI:mainfrom
dpbmaverick98:sql-experiment

Commits on Mar 5, 2026

feat(db): add conversation persistence tables and functions

feat(queue-processor): implement parallel processing and restart recovery

feat(signals): implement push notifications to replace HTTP polling

fix(logging, queue-processor): add await to emitEvent for event ordering guarantee

feat(db): add exponential backoff with jitter to message retry logic

feat(heartbeat): add heartbeat monitoring for crash detection

feat(queue-processor): add message size validation before invokeAgent

fix(queue-processor): serialize inter-agent team conversation updates with conversation lock

fix(signals): handle race condition in signal cleanup with proper error handling

feat(db, queue-processor): add stale conversation recovery for crash resilience

fix(db): improve stale conversation recovery with better pruning and documentation

fix(db, queue-processor): reduce crash detection threshold and add recovery visibility

feat: add database backup strategy and integrity checks (Gap 3)

feat(db): add outstanding_requests table for agent handoff tracking

feat(conversation): integrate outstanding request tracking into agent handoffs

feat(queue-processor): add request timeout checker and ACK handling

fix(queue-processor): complete outstanding request when agent responds

fix(queue-processor): remove duplicate routing log line

fix(db): remove deadline checks from acknowledgeRequest and respondToRequest

fix(queue-processor, db): handle multiple outstanding requests to same agent

feat(queue-processor, db): add missing maintenance and faster timeout checks

docs: add comprehensive agent communication protocol documentation

fix(queue-processor): await chain_step_start emitEvent for visualizer ordering

feat(queue-processor): mark requests as failed when agent errors

chore(queue-processor): remove unused import and fix prune interval

docs: update agent communication protocol with final changes

Commits on Mar 6, 2026

fix(installer): point remote-install to sql-experiment branch

fix(comms): route agent-to-agent responses back to sender

fix(events): emit chain_step_done event after agent completes

fix(install): point remote installer at official repo

fix(events): add .catch() to unawaited emitEvent calls

fix(backup): use atomic sqlite3 .backup instead of sequential cp

fix(db): align max_retries schema default with insert value