Cloudflare Queues based async task bus for Pi agents.
@siygle/agent-queue-shared— shared schemas, IDs, HMAC helpers.@siygle/agent-queue-hub-worker— Cloudflare Worker gateway/router using Queues + D1.@siygle/pi-agent-queue-extension— Pi extension that polls tasks, runs them, and reports results.
POST /taskscreates a task in D1 and enqueues it.- Queue consumer routes task to an agent inbox.
- Pi extension polls
GET /agents/:agentId/tasks/next. - Pi handles task and calls
complete_queue_task. - Extension posts
POST /tasks/:taskId/result.
pnpm install
pnpm build
pnpm testcd packages/hub-worker
wrangler queues create agent-incoming
wrangler queues create agent-results
wrangler d1 create agent-queue
# copy database_id into wrangler.toml
wrangler d1 execute agent-queue --file schema/d1-init.sql
wrangler secret put HUB_TOKEN
pnpm deploycurl -X POST https://agent.sylee.dev/tasks \
-H "Authorization: Bearer $HUB_TOKEN" \
-H "Content-Type: application/json" \
-d '{"target":"pi-market","prompt":"Summarize today market focus"}'