Team Scheduling

import { AgentQueue } from "@radaros/queue";

const queue = new AgentQueue({
  connection: { host: "localhost", port: 6379 },
});

const { jobId } = await queue.enqueueTeamRun({
  teamName: "research-team",
  input: "Analyze Q4 results",
  sessionId: "session-123",
  priority: 1,
});

await queue.schedule({
  id: "daily-analysis",
  cron: "0 9 * * *",
  timezone: "America/New_York",
  team: {
    name: "research-team",
    input: "Generate daily market report",
  },
});

import { AgentWorker } from "@radaros/queue";

const worker = new AgentWorker({
  connection: { host: "localhost", port: 6379 },
  agentRegistry: { analyst: analystAgent },
  teamRegistry: { "research-team": researchTeam },  // new!
  workflowRegistry: { pipeline: dataPipeline },
});