Complex Workflows

git clone https://github.com/astreus-ai/examples
cd examples/complex-workflows
npm install

npm install @astreus-ai/astreus

# .env
OPENAI_API_KEY=sk-your-openai-api-key-here
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.'
});

// Create workflow pipeline
const pipeline = new Graph({
  name: 'content-pipeline'
}, researcher);

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

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

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

// Parse the result and extract the response
if (results.success && results.results[article]) {
  const articleResult = JSON.parse(results.results[article]);
  console.log(articleResult.response);
}

npm run dev