A graph-based task management framework for AI agents
Project description
SocialSeed Tasker
๐ญ Graph-Native Engineering & Autonomous Agent Governance
A specialized framework that leverages Neo4j to provide AI agents with infinite architectural context and strict governance.
๐ Quick Start
1. Start the Services
# Clone and start everything with Docker Compose
git clone https://github.com/daironpf/socialseed-tasker.git
cd socialseed-tasker
docker compose up -d
2. Verify Everything Is Running
# Check API health
curl http://localhost:8000/health
# Expected: {"status":"healthy","version":"0.8.0","neo4j":"connected"}
3. Services Available
| Service | URL | Description |
|---|---|---|
| Neo4j Browser | http://localhost:7474 |
Graph database UI (neo4j/neoSocial) |
| REST API | http://localhost:8000 |
For AI agents to manage issues |
| Frontend | http://localhost:8080 |
Human UI (Kanban board & Interactive Graph View) |
| API Docs | http://localhost:8000/docs |
OpenAPI documentation |
4. Try It Now - 30-Second Demo
# Create a component
COMP_ID=$(curl -s -X POST http://localhost:8000/api/v1/components \
-H "Content-Type: application/json" \
-d '{"name":"backend","project":"my-app"}' | python -c "import sys,json; print(json.load(sys.stdin)['data']['id'])")
# Create an issue in that component
ISSUE_ID=$(curl -s -X POST http://localhost:8000/api/v1/issues \
-H "Content-Type: application/json" \
-d "{\"title\":\"Fix login bug\",\"component_id\":\"$COMP_ID\",\"priority\":\"HIGH\"}" \
| python -c "import sys,json; print(json.load(sys.stdin)['data']['id'])")
# Create a second issue
DEP_ID=$(curl -s -X POST http://localhost:8000/api/v1/issues \
-H "Content-Type: application/json" \
-d "{\"title\":\"Add unit tests\",\"component_id\":\"$COMP_ID\",\"priority\":\"MEDIUM\"}" \
| python -c "import sys,json; print(json.load(sys.stdin)['data']['id'])")
# Link them: Fix login bug depends on Add unit tests
curl -s -X POST "http://localhost:8000/api/v1/issues/$ISSUE_ID/dependencies" \
-H "Content-Type: application/json" \
-d "{\"depends_on_id\":\"$DEP_ID\"}"
# See the dependency chain
curl -s "http://localhost:8000/api/v1/issues/$ISSUE_ID/dependency-chain" | python -m json.tool
# Try to close the issue (will fail - dependency is still open)
curl -s -X POST "http://localhost:8000/api/v1/issues/$ISSUE_ID/close" | python -m json.tool
5. Or Load Full Demo Data
# Via CLI (requires local install)
pip install socialseed-tasker
tasker seed run
# Via API env var (auto-seeds on restart)
TASKER_DEMO_MODE=true docker compose restart tasker-api
6. Explore the Graph
Open http://localhost:7474 in your browser and run this Cypher query to visualize your data:
MATCH (i:Issue)-[:BELONGS_TO]->(c:Component)
RETURN i, c
๐ REST API Reference for AI Agents
Base URL
http://localhost:8000/api/v1
Authentication
Set TASKER_API_KEY and TASKER_AUTH_ENABLED=true for production authentication. Health and docs endpoints remain open.
Components
Components represent different parts of your project (services, modules, packages).
Create Component
curl -X POST http://localhost:8000/api/v1/components \
-H "Content-Type: application/json" \
-d '{
"name": "auth-service",
"description": "Authentication microservice",
"project": "social-network"
}'
List Components
curl http://localhost:8000/api/v1/components
# Filter by project
curl "http://localhost:8000/api/v1/components?project=social-network"
Issues
Create Issue
# First, get a component ID from the list above
COMPONENT_ID=$(curl -s http://localhost:8000/api/v1/components | python -c "import sys,json; print(json.load(sys.stdin)['data'][0]['id'])")
# Then create an issue
curl -X POST http://localhost:8000/api/v1/issues \
-H "Content-Type: application/json" \
-d '{
"title": "Fix login bug with special characters",
"description": "Users cannot login when password contains special chars",
"priority": "HIGH",
"component_id": "'"$COMPONENT_ID"'",
"labels": ["bug", "security"]
}'
Priority values: LOW, MEDIUM, HIGH, CRITICAL
List Issues (Paginated)
# All issues (paginated)
curl "http://localhost:8000/api/v1/issues"
# Response format: {"data": {"items": [...], "total": N, "page": 1, "page_size": 50}}
curl "http://localhost:8000/api/v1/issues?page=1&page_size=20"
# Filter by status
curl "http://localhost:8000/api/v1/issues?status=OPEN"
# Filter by project
curl "http://localhost:8000/api/v1/issues?project=my-app"
# Filter by component
curl "http://localhost:8000/api/v1/issues?component=<component-id>"
# Filter by priority
curl "http://localhost:8000/api/v1/issues?priority=HIGH"
Get Workable Issues
# Get issues where all dependencies are closed (ready to work on)
curl "http://localhost:8000/api/v1/workable-issues"
# With filters
curl "http://localhost:8000/api/v1/workable-issues?priority=HIGH&component=<component-id>"
Update Issue
# Update status
curl -X PATCH http://localhost:8000/api/v1/issues/<issue-id> \
-H "Content-Type: application/json" \
-d '{"status": "IN_PROGRESS"}'
# Mark that an AI agent is working on this issue
curl -X PATCH http://localhost:8000/api/v1/issues/<issue-id> \
-H "Content-Type: application/json" \
-d '{"agent_working": true}'
# Update priority
curl -X PATCH http://localhost:8000/api/v1/issues/<issue-id> \
-H "Content-Type: application/json" \
-d '{"priority": "CRITICAL"}'
# Update description
curl -X PATCH http://localhost:8000/api/v1/issues/<issue-id> \
-H "Content-Type: application/json" \
-d '{"description": "Updated description"}'
# Close an issue
curl -X POST http://localhost:8000/api/v1/issues/<issue-id>/close
Status values: OPEN, IN_PROGRESS, BLOCKED, CLOSED
Delete Issue
curl -X DELETE http://localhost:8000/api/v1/issues/<issue-id>
Dependencies
Dependencies define which issues block others. AI agents use this to understand what can be worked on.
Add Dependency
# Issue A depends on Issue B (B must be completed first)
curl -X POST http://localhost:8000/api/v1/issues/<issue-a-id>/dependencies \
-H "Content-Type: application/json" \
-d '{"depends_on_id": "<issue-b-id>"}'
List Dependencies
# What does this issue depend on?
curl http://localhost:8000/api/v1/issues/<issue-id>/dependencies
Remove Dependency
curl -X DELETE http://localhost:8000/api/v1/issues/<issue-a-id>/dependencies/<issue-b-id>
Get Dependency Graph
# Get full dependency graph for a project
curl "http://localhost:8000/api/v1/graph/dependencies?project=my-app"
# Response: {"nodes": [...], "edges": [...]}
Agent Working Indicator
AI agents can set agent_working: true on an issue to signal they're actively working on it. This displays a cyan robot icon on the Kanban board.
import requests
# Tell the system you're working on this issue
requests.patch(
"http://localhost:8000/api/v1/issues/<issue-id>",
json={"agent_working": True}
)
# When done, clear the flag
requests.patch(
"http://localhost:8000/api/v1/issues/<issue-id>",
json={"agent_working": False}
)
Analysis Endpoints
Impact Analysis
# Analyze what would be affected by an issue
curl "http://localhost:8000/api/v1/analyze/impact/<issue-id>"
# Returns: directly_affected, transitively_affected, blocked_issues, risk_level
Component Impact
# Analyze impact for a component
curl "http://localhost:8000/api/v1/analyze/component-impact/<component-id>"
# Returns: total_issues, affected_components, criticality_score, risk_level
Project Dashboard
Project Summary
# Get complete project summary
curl "http://localhost:8000/api/v1/projects/<project-name>/summary"
# Returns: total_issues, by_status, by_priority, components_count, blocked_issues_count,
# workable_issues_count, dependency_health, top_blocked_components, critical_path_length
Admin Endpoints
Reset Data
# Reset all data or specific scope
curl -X POST "http://localhost:8000/api/v1/admin/reset" \
-H "Content-Type: application/json" \
-d '{"scope": "all"}' # "all", "issues", or "components"
Health Check
# Detailed health with Neo4j connection status
curl http://localhost:8000/health
# Returns: status, version, neo4j (connected/disconnected), neo4j_uri, auth_enabled
Sync Service Endpoints
# Check sync status
curl http://localhost:8000/api/v1/sync/status
# Get sync queue
curl http://localhost:8000/api/v1/sync/queue
# Force sync
curl -X POST http://localhost:8000/api/v1/sync/force
๐ค AI Agent Workflow
Recommended Workflow for AI Agents
import requests
from datetime import datetime
API_BASE = "http://localhost:8000/api/v1"
def start_working_on_issue(issue_id, todo_items):
"""AI agent starts working on an issue - updates status and sets todo."""
# 1. Create a detailed TODO list in the description
todo_text = "## TODO:\n" + "\n".join([f"- [ ] {item}" for item in todo_items])
todo_text += f"\n\n## Progress (started {datetime.now().strftime('%Y-%m-%d %H:%M')}):\n"
requests.patch(f"{API_BASE}/issues/{issue_id}", json={
"description": todo_text,
"agent_working": True,
"status": "IN_PROGRESS"
})
def update_progress(issue_id, completed_item, next_step):
"""Update progress on the issue."""
# Get current description
issue = requests.get(f"{API_BASE}/issues/{issue_id}").json()["data"]
desc = issue.get("description", "")
# Mark completed item
desc = desc.replace(f"- [ ] {completed_item}", f"- [x] {completed_item}")
# Add progress note
desc += f"\n- **In progress**: {next_step}"
requests.patch(f"{API_BASE}/issues/{issue_id}", json={
"description": desc
})
def finish_issue(issue_id, solution_summary):
"""Mark issue as completed with solution summary."""
# Get current description
issue = requests.get(f"{API_BASE}/issues/{issue_id}").json()["data"]
desc = issue.get("description", "")
# Add solution summary
desc += f"\n\n## Solution:\n{solution_summary}"
# Close the issue
requests.post(f"{API_BASE}/issues/{issue_id}/close")
# Clear agent working flag
requests.patch(f"{API_BASE}/issues/{issue_id}", json={
"description": desc,
"agent_working": False
})
Full Example: AI Agent Solving an Issue
import requests
from datetime import datetime
API_BASE = "http://localhost:8000/api/v1"
def solve_issue(issue_id, problem_description):
"""AI agent solves an issue, keeping the board updated with progress."""
todo_items = [
"Analyze the problem and identify root cause",
"Write test to reproduce the issue",
"Implement the fix",
"Run tests to verify the solution",
"Update documentation if needed"
]
initial_desc = f"## Problem\n{problem_description}\n\n"
initial_desc += "## TODO:\n" + "\n".join([f"- [ ] {item}" for item in todo_items])
initial_desc += f"\n\n## Started at: {datetime.now().isoformat()}"
requests.patch(f"{API_BASE}/issues/{issue_id}", json={
"description": initial_desc,
"status": "IN_PROGRESS",
"agent_working": True
})
# Do work and update progress...
# Close with summary
solution_summary = """
## Solution Applied
- Added null validation for password field
- Added test case with special characters
- All existing tests continue to pass
"""
requests.post(f"{API_BASE}/issues/{issue_id}/close")
requests.patch(f"{API_BASE}/issues/{issue_id}", json={
"description": initial_desc + solution_summary,
"agent_working": False
})
Finding Workable Issues
def get_workable_issues():
"""Get issues that can be worked on (not blocked)."""
response = requests.get(f"{API_BASE}/workable-issues")
return response.json()["data"]["items"]
๐ง Environment Variables
| Variable | Default | Description |
|---|---|---|
TASKER_NEO4J_URI |
bolt://localhost:7687 |
Neo4j connection URI |
TASKER_NEO4J_USER |
neo4j |
Neo4j username |
TASKER_NEO4J_PASSWORD |
(none) | Neo4j password (required) |
API_PORT |
8000 |
API server port |
TASKER_API_KEY |
(none) | API key for authentication |
TASKER_AUTH_ENABLED |
false |
Enable API authentication |
TASKER_DEMO_MODE |
false |
Load demo data on startup |
TASKER_RATE_LIMIT |
100 |
Requests per minute limit |
๐ณ Docker Compose
The included docker-compose.yml starts:
- Neo4j (port 7474/7687) - Graph database
- API (port 8000) - REST API for AI agents
- Frontend (port 8080) - Human Kanban board
# Start everything
docker compose up -d
# View logs
docker compose logs -f
# Stop everything (data persists in Docker volume)
docker compose down
# Stop and remove all data
docker compose down -v
Data Persistence: All data is stored in Neo4j and persists between
docker compose downanddocker compose upcycles. Usedocker compose down -vto completely reset the database.
๐ Architecture
โโโโโโโโโโโโโโโโโโโโโโโโโโโโ
โ AI Agent / Human UI โ
โ REST API (port 8000) โ
โโโโโโโโโโโโโโฌโโโโโโโโโโโโโโ
โผ
โโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโ
โ Application Core โ
โ (Hexagonal Architecture) โ
โ โข Governance Engine โ
โ โข Dependency BFS Analysis โ
โ โข Root Cause Detection โ
โ โข Input Validation โ
โ โข Rate Limiting โ
โโโโโโโโโโโโโโฌโโโโโโโโโโโโโโโโโโ
โผ
โโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโ
โ Neo4j Graph DB โ
โ (The Source of Truth) โ
โ โข Relationship Tracking โ
โ โข Causal Traceability โ
โโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโ
๐ Related Documentation
- CLI Reference - Command-line interface
- API_REFERENCE.md - Complete API endpoint reference for AI agents
- VERSIONS.md - Release milestones and feature checklists
- Development - Running tests, contributing
Project details
Download files
Download the file for your platform. If you're not sure which to choose, learn more about installing packages.
Source Distribution
Built Distribution
Filter files by name, interpreter, ABI, and platform.
If you're not sure about the file name format, learn more about wheel file names.
Copy a direct link to the current filters
File details
Details for the file
socialseed_tasker-0.8.0.tar.gz.File metadata
File hashes
ea264ddff6220590306ca2256ec9e5a691b846329987071ad221c5b7158adbe1284806c1266c3493ecb53f6ed359f0af4f204e944cb2b3d6cce825caa723221cf1ba1afe221c1ed8fe9aec69d75ecd93See more details on using hashes here.