Multi-Agent on AWS

123456789101112
{
  "Comment": "Multi-Agent Analysis Workflow",
  "StartAt": "ClassifyTask",
  "States": {
    "ClassifyTask": {
      "Type": "Task",
      "Resource": "arn:aws:lambda:us-east-1:123456789:function:task-classifier",
      "Next": "RouteToAgents"
    },
    "RouteToAgents": {
      "Type": "Parallel",
      "Branches": [

123456789101112
{
  "Comment": "Multi-agent research orchestration",
  "StartAt": "ParseQuery",
  "States": {
    "ParseQuery": {
      "Type": "Task",
      "Resource": "arn:aws:lambda:us-east-1:123456789:function:query-agent",
      "ResultPath": "$.queryAnalysis",
      "Next": "ParallelResearch"
    },
    "ParallelResearch": {
      "Type": "Parallel",

12345678910
{
  "Source": ["agent.orchestrator"],
  "DetailType": ["AgentTaskRequest"],
  "Detail": {
    "taskType": ["research"],
    "complexity": [{ "numeric": [">", 0.7] }],
    "domain": [{ "prefix": "technical" }],
    "requiresRealtime": [false]
  }
}

123456789101112
import * as sfn from 'aws-cdk-lib/aws-stepfunctions';
import * as tasks from 'aws-cdk-lib/aws-stepfunctions-tasks';

// Agent task definitions
const extractAgent = new tasks.LambdaInvoke(this, 'ExtractAgent', {
  lambdaFunction: extractorFn,
  outputPath: '$.Payload',
  retryOnServiceExceptions: true,
});

const classifyAgent = new tasks.LambdaInvoke(this, 'ClassifyAgent', {
  lambdaFunction: classifierFn,

123456789101112
import boto3
import json
from datetime import datetime

events_client = boto3.client('events')

class AgentEventEmitter:
    def __init__(self, agent_name: str, event_bus: str = 'agent-communication'):
        self.agent_name = agent_name
        self.event_bus = event_bus
    
    def emit_task_completed(self, task_id: str, result: dict, 

123456789101112
import json
from typing import List, Dict, Any
from dataclasses import dataclass
import numpy as np

@dataclass
class AgentResponse:
    agent_name: str
    findings: List[str]
    confidence: float
    reasoning: str
    success: bool

123456789101112
// Step Functions definition for saga pattern
const sagaDefinition = {
  StartAt: 'CreateOrder',
  States: {
    CreateOrder: {
      Type: 'Task',
      Resource: '${CreateOrderFn.Arn}',
      ResultPath: '$.orderResult',
      Next: 'ProcessPayment',
      Catch: [{
        ErrorEquals: ['States.ALL'],
        ResultPath: '$.error',