Complex Workflows

# .env
# LLM API key for all agents
OPENAI_API_KEY=sk-your-openai-api-key-here

# Database for agents and graph persistence
DB_URL=sqlite://./astreus.db

import { Agent, Graph } from '@astreus-ai/astreus';

// Create specialized agents
const researcher = await Agent.create({
  name: 'Researcher',
  model: 'gpt-4o',
  systemPrompt: 'You research topics thoroughly.'
});

const writer = await Agent.create({
  name: 'Writer',
  model: 'gpt-4o',
  systemPrompt: 'You create engaging content.'
});

const editor = await Agent.create({
  name: 'Editor',
  model: 'gpt-4o',
  systemPrompt: 'You review and polish content.'
});

// Create complex pipeline
const pipeline = new Graph({
  name: 'content-pipeline',
  defaultAgentId: researcher.id,
  maxConcurrency: 2
});

// Research phase
const research = pipeline.addTaskNode({
  prompt: 'Research AI trends in 2024',
  agentId: researcher.id
});

// Writing phase
const writing = pipeline.addTaskNode({
  prompt: 'Write an article based on the research',
  agentId: writer.id,
  dependencies: [research]
});

// Editing phase
const editing = pipeline.addTaskNode({
  prompt: 'Review and polish the article',
  agentId: editor.id,
  dependencies: [writing]
});

// Execute pipeline
const results = await pipeline.run();

console.log('Final article:', results.results[editing].response);