With the rise of AI in finance, investors are increasingly leveraging AI-driven insights for better decision-making. This article explores how we can create a hierarchical multi-agent AI system using LangGraph Supervisor to analyze financial market trends, perform sentiment analysis, and provide investment recommendations. By integrating specialized agents for market data retrieval, sentiment analysis, quantitative analysis, and investment strategy formulation, we enable an intelligent, automated system that mimics the workflow of human financial analysts.<\/p>\n
Learning Objectives<\/h4>\n\n- Learn hierarchical structures, supervisor roles, and agent coordination.<\/li>\n
- Build domain-specific, sentiment, and quantitative analysis agents.<\/li>\n
- Manage agent communication and configure hierarchical workflows.<\/li>\n
- Integrate AI insights for data-driven recommendations.<\/li>\n
- Implement, optimize, and scale AI-driven applications.<\/li>\n
- Mitigate biases, ensure transparency, and enhance reliability.<\/li>\n
- This module provides a hands-on approach to building intelligent, AI-driven multi-agent systems using scalable frameworks.<\/li>\n<\/ul>\n
This article was published as a part of the\u00a0<\/strong><\/em>Data Science Blogathon.<\/strong><\/em><\/a><\/p>\nMulti-Agent AI System: LangChain Supervisor<\/h2>\n
Here\u2019s a simple example of a supervisor managing two specialized agents:<\/p>\n
\n![\"supervisor\"](\"https:\/\/cdn.analyticsvidhya.com\/wp-content\/uploads\/2025\/02\/supervisor.webp\")
Source: Langchain Supervisor<\/figcaption><\/figure>\n<\/div>\nYou can control how agent messages are added to the overall conversation history of the multi-agent system:<\/p>\n
Include full message history from an agent:<\/p>\n
\n![\"LangChain](\"https:\/\/cdn.analyticsvidhya.com\/wp-content\/uploads\/2025\/02\/full_history.webp\")
Source: Langchain Supervisor<\/figcaption><\/figure>\n<\/div>\nThe Multi-Agent Architecture<\/h2>\n
Our system consists of five specialized AI agents<\/a> working in a coordinated manner:<\/p>\n\n- Market Data Agent<\/b> (market_data_expert<\/i>) \u2013 Fetches real-time stock prices, P\/E ratios, EPS, and revenue growth. Responsible for fetching real-time financial data, including stock prices, price-to-earnings (P\/E) ratios, earnings per share (EPS), and revenue growth. Ensures that the system has up-to-date market data for analysis.<\/li>\n
- Sentiment Analysis Agent<\/b> (sentiment_expert<\/i>) \u2013 Analyzes news and social media sentiment for stocks. Categorizes sentiment as positive, neutral, or negative to assess the market mood toward specific stocks.<\/li>\n
- Quantitative Analy<\/b>sis Agent (quant_expert<\/i>) \u2013 Computes stock price trends, moving averages, and volatility metrics. Helps detect trends, potential breakout points, and risk levels based on past market data.<\/li>\n
- Investment Strategy Agent<\/b> (strategy_expert<\/i>) \u2013 Uses all available insights to generate a Buy\/Sell\/Hold recommendation. Determines whether a stock should be marked as a Buy, Sell, or Hold based on calculated risks and opportunities.<\/li>\n
- Supervisor Agent<\/b> (market_supervisor<\/i>) \u2013 Manages all agents, ensuring smooth task delegation and decision-making. Coordinates multi-agent interactions, monitors workflow efficiency and aggregates final recommendations for the user.<\/li>\n<\/ul>\n
Hands-on Multi-Agent AI System for Financial Market Analysis<\/h2>\n1. Setting Up the Environment<\/h3>\n
Before implementing the system, install the necessary dependencies:<\/p>\n
!pip install langgraph-supervisor langchain-openai<\/code><\/pre>\nSet up your OpenAI API key securely:<\/p>\n
import os\nos.environ[\"OPENAI_API_KEY\"] = \"\"<\/your_api_key><\/code><\/pre>\n2. Defining Specialized Agent Functions<\/h3>\nFetching Market Data<\/h4>\n# 1. Fetching Market Data\ndef fetch_market_data(stock_symbol: str) -> dict:\n \"\"\"Simulate fetching stock market data for a given symbol.\"\"\"\n market_data = {\n \"AAPL\": {\"price\": 185.22, \"pe_ratio\": 28.3, \"eps\": 6.5, \"revenue_growth\": 8.5},\n \"GOOG\": {\"price\": 142.11, \"pe_ratio\": 26.1, \"eps\": 5.8, \"revenue_growth\": 7.9},\n \"TSLA\": {\"price\": 220.34, \"pe_ratio\": 40.2, \"eps\": 3.5, \"revenue_growth\": 6.2},\n }\n return market_data.get(stock_symbol, {})<\/code><\/pre>\nPerforming Sentiment Analysis<\/h4>\n# 2. Sentiment Analysis\ndef analyze_sentiment(stock_symbol: str) -> dict:\n \"\"\"Perform sentiment analysis on financial news for a stock.\"\"\"\n sentiment_scores = {\n \"AAPL\": {\"news_sentiment\": \"Positive\", \"social_sentiment\": \"Neutral\"},\n \"GOOG\": {\"news_sentiment\": \"Negative\", \"social_sentiment\": \"Positive\"},\n \"TSLA\": {\"news_sentiment\": \"Positive\", \"social_sentiment\": \"Negative\"},\n }\n return sentiment_scores.get(stock_symbol, {})<\/code><\/pre>\nComputing Quantitative Analysis Metrics<\/h4>\n# 3. Quantitative Analysis\ndef compute_quant_metrics(stock_symbol: str) -> dict:\n \"\"\"Compute SMA, EMA, and volatility for stock.\"\"\"\n quant_metrics = {\n \"AAPL\": {\"sma_50\": 180.5, \"ema_50\": 182.1, \"volatility\": 1.9},\n \"GOOG\": {\"sma_50\": 140.8, \"ema_50\": 141.3, \"volatility\": 2.1},\n \"TSLA\": {\"sma_50\": 215.7, \"ema_50\": 218.2, \"volatility\": 3.5},\n }\n return quant_metrics.get(stock_symbol, {})<\/code><\/pre>\nGenerating Investment Recommendations<\/h4>\n# 4. Investment Strategy Decision\ndef investment_strategy(stock_symbol: str, market_data: dict, sentiment: dict, quant: dict) -> str:\n \"\"\"Analyze data and generate buy\/sell\/hold recommendation.\"\"\"\n if not market_data or not sentiment or not quant:\n return \"Not enough data for recommendation.\"\n\n decision = \"Hold\"\n if market_data[\"pe_ratio\"] 35 or sentiment[\"news_sentiment\"] == \"Negative\":\n decision = \"Sell\"\n\n return f\"Recommended Action for {stock_symbol}: {decision}\"<\/code><\/pre>\n3. Creating and Deploying Agents<\/h3>\nimport os\nfrom langchain_openai import ChatOpenAI\nfrom langgraph_supervisor import create_supervisor\nfrom langgraph.prebuilt import create_react_agent\n\n# Initialize the Chat model\nmodel = ChatOpenAI(model=\"gpt-4o\")\n\n### --- CREATE AGENTS --- ###\n\n# Market Data Agent\nmarket_data_expert = create_react_agent(\n model=model,\n tools=[fetch_market_data],\n name=\"market_data_expert\",\n prompt=\"You are an expert in stock market data. Fetch stock data when requested.\"\n)\n\n# Sentiment Analysis Agent\nsentiment_expert = create_react_agent(\n model=model,\n tools=[analyze_sentiment],\n name=\"sentiment_expert\",\n prompt=\"You analyze financial news and social media sentiment for stock symbols.\"\n)\n\n# Quantitative Analysis Agent\nquant_expert = create_react_agent(\n model=model,\n tools=[compute_quant_metrics],\n name=\"quant_expert\",\n prompt=\"You analyze stock price trends, moving averages, and volatility metrics.\"\n)\n\n# Investment Strategy Agent\nstrategy_expert = create_react_agent(\n model=model,\n tools=[investment_strategy],\n name=\"strategy_expert\",\n prompt=\"You make investment recommendations based on market, sentiment, and quant data.\"\n)\n\n### --- SUPERVISOR AGENT --- ###\n\nmarket_supervisor = create_supervisor(\n agents=[market_data_expert, sentiment_expert, quant_expert, strategy_expert],\n model=model,\n prompt=(\n \"You are a financial market supervisor managing four expert agents: market data, sentiment, \"\n \"quantitative analysis, and investment strategy. For stock queries, use market_data_expert. \"\n \"For news\/social sentiment, use sentiment_expert. For stock price analysis, use quant_expert. \"\n \"For final investment recommendations, use strategy_expert.\"\n )\n)\n\n# Compile into an executable workflow\napp = market_supervisor.compile()<\/code><\/pre>\n4. Running the System<\/h3>\n### --- RUN THE SYSTEM --- ###\nstock_query = {\n \"messages\": [\n {\"role\": \"user\", \"content\": \"What is the investment recommendation for AAPL?\"}\n ]\n}\n\n# Execute query\nresult = app.invoke(stock_query)\n\nprint(result['messages'][-1].content)<\/code><\/pre>\n\n![\"Output\"](\"https:\/\/cdn.analyticsvidhya.com\/wp-content\/uploads\/2025\/02\/image_eUnjGDr.webp\")
Output<\/figcaption><\/figure>\n<\/div>\nThe AI system has analyzed market data, sentiment, and technical indicators to recommend an investment action<\/p>\n
Future Enhancements<\/h2>\n\n- Connect to Real APIs (Yahoo Finance, Alpha Vantage) for livestock data.<\/li>\n
- Enhance Sentiment Analysis<\/a> by integrating social media monitoring.<\/li>\n
- Expand Portfolio Management to include risk assessment and diversification strategies.<\/li>\n<\/ul>\n
This multi-agent framework is a scalable AI solution for financial analysis, capable of real-time investment decision-making with minimal human intervention!\u00a0<\/p>\n
Key Takeaways<\/h2>\n\n- A multi-agent AI system automates market trend analysis, sentiment evaluation, and investment recommendations.<\/li>\n
- Specialized agents handle market data, sentiment analysis, quantitative metrics, and investment strategy, managed by a supervisor agent.<\/li>\n
- The system is built using LangGraph Supervisor, defining agent functions, deploying them, and running investment queries.<\/li>\n
- The multi-agent approach enhances modularity, scalability, automation, and accuracy in financial decision-making.<\/li>\n
- Integration of real-time financial APIs, advanced sentiment tracking, and portfolio management for a more comprehensive AI-powered investment system.<\/li>\n<\/ul>\n
The media shown in this article is not owned by Analytics Vidhya and is used at the Author\u2019s discretion.<\/strong><\/p>\nFrequently Asked Questions<\/h2>\n
This article was published as a part of the\u00a0<\/strong><\/em>Data Science Blogathon.<\/strong><\/em><\/a><\/p>\n Here\u2019s a simple example of a supervisor managing two specialized agents:<\/p>\n You can control how agent messages are added to the overall conversation history of the multi-agent system:<\/p>\n Include full message history from an agent:<\/p>\n Our system consists of five specialized AI agents<\/a> working in a coordinated manner:<\/p>\n Before implementing the system, install the necessary dependencies:<\/p>\n Set up your OpenAI API key securely:<\/p>\n The AI system has analyzed market data, sentiment, and technical indicators to recommend an investment action<\/p>\n This multi-agent framework is a scalable AI solution for financial analysis, capable of real-time investment decision-making with minimal human intervention!\u00a0<\/p>\n The media shown in this article is not owned by Analytics Vidhya and is used at the Author\u2019s discretion.<\/strong><\/p>\nMulti-Agent AI System: LangChain Supervisor<\/h2>\n
The Multi-Agent Architecture<\/h2>\n
\n
Hands-on Multi-Agent AI System for Financial Market Analysis<\/h2>\n
1. Setting Up the Environment<\/h3>\n
!pip install langgraph-supervisor langchain-openai<\/code><\/pre>\nimport os\nos.environ[\"OPENAI_API_KEY\"] = \"2. Defining Specialized Agent Functions<\/h3>\n
Fetching Market Data<\/h4>\n
# 1. Fetching Market Data\ndef fetch_market_data(stock_symbol: str) -> dict:\n \"\"\"Simulate fetching stock market data for a given symbol.\"\"\"\n market_data = {\n \"AAPL\": {\"price\": 185.22, \"pe_ratio\": 28.3, \"eps\": 6.5, \"revenue_growth\": 8.5},\n \"GOOG\": {\"price\": 142.11, \"pe_ratio\": 26.1, \"eps\": 5.8, \"revenue_growth\": 7.9},\n \"TSLA\": {\"price\": 220.34, \"pe_ratio\": 40.2, \"eps\": 3.5, \"revenue_growth\": 6.2},\n }\n return market_data.get(stock_symbol, {})<\/code><\/pre>\nPerforming Sentiment Analysis<\/h4>\n
# 2. Sentiment Analysis\ndef analyze_sentiment(stock_symbol: str) -> dict:\n \"\"\"Perform sentiment analysis on financial news for a stock.\"\"\"\n sentiment_scores = {\n \"AAPL\": {\"news_sentiment\": \"Positive\", \"social_sentiment\": \"Neutral\"},\n \"GOOG\": {\"news_sentiment\": \"Negative\", \"social_sentiment\": \"Positive\"},\n \"TSLA\": {\"news_sentiment\": \"Positive\", \"social_sentiment\": \"Negative\"},\n }\n return sentiment_scores.get(stock_symbol, {})<\/code><\/pre>\nComputing Quantitative Analysis Metrics<\/h4>\n
# 3. Quantitative Analysis\ndef compute_quant_metrics(stock_symbol: str) -> dict:\n \"\"\"Compute SMA, EMA, and volatility for stock.\"\"\"\n quant_metrics = {\n \"AAPL\": {\"sma_50\": 180.5, \"ema_50\": 182.1, \"volatility\": 1.9},\n \"GOOG\": {\"sma_50\": 140.8, \"ema_50\": 141.3, \"volatility\": 2.1},\n \"TSLA\": {\"sma_50\": 215.7, \"ema_50\": 218.2, \"volatility\": 3.5},\n }\n return quant_metrics.get(stock_symbol, {})<\/code><\/pre>\nGenerating Investment Recommendations<\/h4>\n
# 4. Investment Strategy Decision\ndef investment_strategy(stock_symbol: str, market_data: dict, sentiment: dict, quant: dict) -> str:\n \"\"\"Analyze data and generate buy\/sell\/hold recommendation.\"\"\"\n if not market_data or not sentiment or not quant:\n return \"Not enough data for recommendation.\"\n\n decision = \"Hold\"\n if market_data[\"pe_ratio\"] 35 or sentiment[\"news_sentiment\"] == \"Negative\":\n decision = \"Sell\"\n\n return f\"Recommended Action for {stock_symbol}: {decision}\"<\/code><\/pre>\n3. Creating and Deploying Agents<\/h3>\n
import os\nfrom langchain_openai import ChatOpenAI\nfrom langgraph_supervisor import create_supervisor\nfrom langgraph.prebuilt import create_react_agent\n\n# Initialize the Chat model\nmodel = ChatOpenAI(model=\"gpt-4o\")\n\n### --- CREATE AGENTS --- ###\n\n# Market Data Agent\nmarket_data_expert = create_react_agent(\n model=model,\n tools=[fetch_market_data],\n name=\"market_data_expert\",\n prompt=\"You are an expert in stock market data. Fetch stock data when requested.\"\n)\n\n# Sentiment Analysis Agent\nsentiment_expert = create_react_agent(\n model=model,\n tools=[analyze_sentiment],\n name=\"sentiment_expert\",\n prompt=\"You analyze financial news and social media sentiment for stock symbols.\"\n)\n\n# Quantitative Analysis Agent\nquant_expert = create_react_agent(\n model=model,\n tools=[compute_quant_metrics],\n name=\"quant_expert\",\n prompt=\"You analyze stock price trends, moving averages, and volatility metrics.\"\n)\n\n# Investment Strategy Agent\nstrategy_expert = create_react_agent(\n model=model,\n tools=[investment_strategy],\n name=\"strategy_expert\",\n prompt=\"You make investment recommendations based on market, sentiment, and quant data.\"\n)\n\n### --- SUPERVISOR AGENT --- ###\n\nmarket_supervisor = create_supervisor(\n agents=[market_data_expert, sentiment_expert, quant_expert, strategy_expert],\n model=model,\n prompt=(\n \"You are a financial market supervisor managing four expert agents: market data, sentiment, \"\n \"quantitative analysis, and investment strategy. For stock queries, use market_data_expert. \"\n \"For news\/social sentiment, use sentiment_expert. For stock price analysis, use quant_expert. \"\n \"For final investment recommendations, use strategy_expert.\"\n )\n)\n\n# Compile into an executable workflow\napp = market_supervisor.compile()<\/code><\/pre>\n4. Running the System<\/h3>\n
### --- RUN THE SYSTEM --- ###\nstock_query = {\n \"messages\": [\n {\"role\": \"user\", \"content\": \"What is the investment recommendation for AAPL?\"}\n ]\n}\n\n# Execute query\nresult = app.invoke(stock_query)\n\nprint(result['messages'][-1].content)<\/code><\/pre>\nFuture Enhancements<\/h2>\n
\n
Key Takeaways<\/h2>\n
\n
Frequently Asked Questions<\/h2>\n
![\"Adarsh](\"https:\/\/av-eks-lekhak.s3.amazonaws.com\/media\/lekhak-profile-images\/converted_image_tHXFGNS.webp\")
<\/p>\n