Dispatch Quality Control Agents with smolagents and OpenAI Agents SDK

                      
                     
from typing import Dict, Any
import os
import logging
from smolagents import AgentManager
from openai import OpenAI

# Configuration
API_KEY = os.getenv('OPENAI_API_KEY')
AGENT_COUNT = int(os.getenv('AGENT_COUNT', 5))

# Setup logging
logging.basicConfig(level=logging.INFO)
logger = logging.getLogger(__name__)

# Initialize OpenAI and Agent Manager
openai_client = OpenAI(api_key=API_KEY)
agent_manager = AgentManager(openai_client)

# Core logic to dispatch agents
async def dispatch_agents(task: Dict[str, Any]) -> Dict[str, Any]:
    try:
        logger.info('Dispatching agents...')
        results = await agent_manager.run_agents(task, count=AGENT_COUNT)
        return {'success': True, 'results': results}
    except Exception as error:
        logger.error(f'Error dispatching agents: {error}')
        return {'success': False, 'error': str(error)}

if __name__ == '__main__':
    # Example task
    task = {'quality_check': 'Inspect the latest batch of products.'}
    result = dispatch_agents(task)
    print(result)