TaskQueue#

Priority task queue for agent workflows.

Start the server#

bash

uvicorn taskqueue.app:app --port 8014

Create a task#

bash

curl -s -X POST http://localhost:8014/v1/tasks \
  -H "Content-Type: application/json" \
  -d '{"title": "Scan skill", "payload": {"skill": "my-skill"}, "priority": 5, "tags": ["security"]}' | jq

Claim the next task (highest priority first)#

bash

curl -s -X POST http://localhost:8014/v1/claim | jq

Returns the task with status changed to running.

Complete or fail a task#

bash

curl -s -X POST http://localhost:8014/v1/tasks/TASK_ID/complete \
  -H "Content-Type: application/json" \
  -d '{"result": {"output": "all clear"}}' | jq

curl -s -X POST http://localhost:8014/v1/tasks/TASK_ID/fail \
  -H "Content-Type: application/json" \
  -d '{"error": "scan timed out"}' | jq

List and filter tasks#

bash

curl -s "http://localhost:8014/v1/tasks?status=pending" | jq
curl -s "http://localhost:8014/v1/tasks?tag=security" | jq

Queue stats#

bash

curl -s http://localhost:8014/v1/stats | jq

Returns total, pending, running, completed, failed.

Endpoints#

MethodPathDescriptionPOST/v1/tasksCreate a taskGET/v1/tasksList tasks (filter: ?status=, ?tag=)GET/v1/tasks/{id}Get task by IDPOST/v1/claimClaim next pending taskPOST/v1/tasks/{id}/completeMark done with resultPOST/v1/tasks/{id}/failMark failed with errorGET/v1/statsQueue statistics