Skip to content

Latest commit

ย 

History

13 Commits

Folders and files

NameName
Last commit message
Last commit date
ย 
ย 
ย 
ย 
ย 
ย 
ย 
ย 

Repository files navigation

AI-Multi-Agent-Swarm-System

AI-powered multi-agent workflow automation system using Kanban-based task orchestration, dependency tracking, and intelligent agent collaboration.

Multi-Agent Swarm System Banner


๐Ÿค– Multi-Agent Swarm System

AI-Powered Multi-Agent Platform for Kanban-Based Task Orchestration

Built with: Python 3.10+ ยท LangGraph (Agent Orchestration) ยท LangChain (Framework) ยท Flask (Backend API) License: MIT ย |ย  Status: Active ย |ย  Made by: Atharva Shevate

A Python-powered multi-agent system that assigns tasks, tracks dependencies, and executes workflows on a Kanban board โ€” turning manual task management into a fully autonomous AI pipeline.


๐Ÿ“– Project Overview

Multi-Agent Swarm System is a production-grade autonomous task orchestration platform built using LangGraph and LangChain. Instead of relying on a single monolithic AI model, the system deploys a swarm of specialized AI agents โ€” each responsible for one specific role in the workflow pipeline. These agents communicate through a shared state graph, cooperate in real time, and collectively drive tasks from submission to completion โ€” fully automatically.

The core idea is simple but powerful: manually tracking tasks, checking dependencies, and assigning work doesn't scale. This system replaces that manual overhead with a coordinated team of autonomous agents that operate faster, more consistently, and without supervision.

Progress is reflected in real time on a Kanban board โ€” giving full visibility into what each agent is doing and where every task stands in the pipeline. The entire system is exposed through a Flask REST API, making it easy to integrate with any external tool or dashboard.

๐Ÿ“… Built: December 2025 ย |ย  ๐Ÿซ Vishwakarma University, Pune (B.Tech Computer Engineering 2026) ๐Ÿ‘จโ€๐Ÿ’ป Author: Atharva Shevate ย |ย  ๐Ÿ’ผ AI Engineer Intern @ IOTIOT.IN, Pune


โœจ Key Features

Feature Description
๐Ÿง  Multi-Agent Collaboration Four specialized agents (Analysis, Dependency, Assignment, Execution) operate on a shared LangGraph state graph, each handling a distinct phase of the workflow
๐Ÿ—‚๏ธ Kanban Workflow Management Tasks automatically progress through To Do โ†’ In Progress โ†’ Review โ†’ Done columns with no manual intervention
โš™๏ธ Automated Task Assignment The Assignment Agent places tasks into the correct Kanban column based on priority, category, dependency status, and agent workload
๐Ÿ”— Dependency Tracking A dedicated Dependency Checker Agent validates that all prerequisite tasks are complete before allowing dependent tasks to execute
โšก Workflow Execution Pipelines Eligible tasks are automatically picked up by the Execution Agent and run end-to-end through the pipeline
๐Ÿ”Œ REST API Interface Flask-powered API endpoints expose full task CRUD operations, status queries, and pipeline controls
๐Ÿ“Š Real-Time Kanban Board Live visual board shows current task states, agent assignments, and workflow progress
๐Ÿ”„ State Machine Architecture LangGraph manages the entire agent lifecycle through a typed state graph with well-defined transitions
๐Ÿ”’ Secure Configuration All API keys and credentials are isolated in environment variables โ€” never hard-coded
๐Ÿ“ˆ Full Audit Trail Every agent decision is logged with timestamp, agent identity, task ID, and transition reason

โš™๏ธ Agent Architecture

(Architecture diagram: a central LangGraph Orchestrator coordinates four specialist agents โ€” Task Analysis, Dependency Checker, Task Assignment, and Execution โ€” each connected to a shared state graph.)

The system deploys four specialist agents coordinated by a central LangGraph Orchestrator. Each agent is stateless on its own โ€” all shared context lives in the LangGraph state graph, which acts as the single source of truth for the entire workflow.

๐Ÿง  Task Analysis Agent

The entry point for every task in the system. When a new task is submitted via the API, this agent:

  • Parses the raw task payload (title, description, tags, deadline)
  • Assigns a priority level (High / Medium / Low) based on urgency signals
  • Extracts category and metadata for downstream routing decisions
  • Determines the optimal execution strategy (parallel vs sequential)
  • Emits the enriched task object into the shared state graph

๐Ÿ”— Dependency Checker Agent

Before any task can proceed to assignment, this agent validates its dependency chain:

  • Queries the state graph for all tasks listed as prerequisites
  • Checks the completion status of each dependency
  • Blocks dependent tasks that have unresolved prerequisites
  • Unblocks tasks as their dependencies complete
  • Resolves complex dependency graphs (multi-level chains, circular detection)

๐Ÿ“‹ Task Assignment Agent

Once a task passes dependency validation, this agent handles placement:

  • Selects the appropriate Kanban column based on task state
  • Balances workload across available execution slots
  • Transitions the task card from To Do โ†’ In Progress
  • Records the assignment decision in the audit log
  • Notifies the Execution Agent that a new task is ready

โšก Execution Agent

The final stage of the pipeline โ€” this agent drives tasks to completion:

  • Picks up tasks marked as In Progress and executes the defined workflow pipeline
  • Updates the shared state on each step completion
  • Moves the task card through Review โ†’ Done
  • Emits a completion event that may unblock downstream dependent tasks
  • Handles retries and error states with configurable backoff

๐Ÿ”„ LangGraph Orchestrator

The backbone of the entire system:

  • Maintains the typed shared state graph across all agents
  • Routes messages and triggers between agents based on state transitions
  • Manages the agent lifecycle (init, run, suspend, resume)
  • Ensures consistency โ€” no two agents modify the same task state simultaneously

๐Ÿ› ๏ธ Tech Stack

(Tech stack overview: core framework, AI/agent layer, frontend visualization, and developer tooling used across the project.)

Core Framework

Python 3.10+          โ€” Primary language for all modules
LangGraph             โ€” Agent orchestration via typed state graph
LangChain             โ€” LLM abstraction, prompt templates, agent primitives
Flask                 โ€” Lightweight REST API backend
REST APIs             โ€” Task CRUD, status queries, pipeline controls

AI & Agent Layer

AI Agents             โ€” Four specialized autonomous agents
Multi-Agent Systems   โ€” Swarm coordination via shared state
Dependency Graph      โ€” DAG-based prerequisite resolution
State Machine         โ€” LangGraph-managed lifecycle transitions
LLM Integration       โ€” Language model calls via LangChain abstractions

Frontend & Visualization

Kanban Board          โ€” Live task status visualization
JavaScript            โ€” Board interactivity and real-time updates
HTML / CSS            โ€” Dashboard layout and styling
REST Integration      โ€” Board polls Flask API for live state

Developer Tools

Git / GitHub          โ€” Version control and project hosting
Python-dotenv         โ€” Environment variable management (.env)
Virtual Environment   โ€” Isolated dependency management
Linux / Ubuntu        โ€” Development and deployment OS
VS Code / PyCharm     โ€” Development environment

๐Ÿ–ผ๏ธ Screenshots

Multi-Agent Swarm System


๐Ÿ”„ How It Works โ€” Detailed Walkthrough

New Task Submitted
       โ”‚
       โ–ผ
โ”Œโ”€โ”€โ”€โ”€โ”€โ”€โ”€โ”€โ”€โ”€โ”€โ”€โ”€โ”€โ”€โ”€โ”€โ”€โ”€โ”€โ”€โ”€โ”€โ”€โ”€โ”€โ”€โ”€โ”€โ”€โ”€โ”€โ”€โ”
โ”‚   ๐Ÿง   Task Analysis Agent       โ”‚
โ”‚   Parse โ†’ Prioritize โ†’ Route    โ”‚
โ””โ”€โ”€โ”€โ”€โ”€โ”€โ”€โ”€โ”€โ”€โ”€โ”€โ”€โ”€โ”€โ”€โ”ฌโ”€โ”€โ”€โ”€โ”€โ”€โ”€โ”€โ”€โ”€โ”€โ”€โ”€โ”€โ”€โ”€โ”˜
                 โ”‚
                 โ–ผ
โ”Œโ”€โ”€โ”€โ”€โ”€โ”€โ”€โ”€โ”€โ”€โ”€โ”€โ”€โ”€โ”€โ”€โ”€โ”€โ”€โ”€โ”€โ”€โ”€โ”€โ”€โ”€โ”€โ”€โ”€โ”€โ”€โ”€โ”€โ”
โ”‚   ๐Ÿ”—  Dependency Checker Agent  โ”‚
โ”‚   Validate prerequisites         โ”‚
โ”‚   Block if unresolved           โ”‚
โ”‚   Unblock when deps complete    โ”‚
โ””โ”€โ”€โ”€โ”€โ”€โ”€โ”€โ”€โ”€โ”€โ”€โ”€โ”€โ”€โ”€โ”€โ”ฌโ”€โ”€โ”€โ”€โ”€โ”€โ”€โ”€โ”€โ”€โ”€โ”€โ”€โ”€โ”€โ”€โ”˜
                 โ”‚  (dependencies clear)
                 โ–ผ
โ”Œโ”€โ”€โ”€โ”€โ”€โ”€โ”€โ”€โ”€โ”€โ”€โ”€โ”€โ”€โ”€โ”€โ”€โ”€โ”€โ”€โ”€โ”€โ”€โ”€โ”€โ”€โ”€โ”€โ”€โ”€โ”€โ”€โ”€โ”
โ”‚   ๐Ÿ“‹  Task Assignment Agent     โ”‚
โ”‚   Select column โ†’ Place on boardโ”‚
โ”‚   TO DO โ†’ IN PROGRESS           โ”‚
โ””โ”€โ”€โ”€โ”€โ”€โ”€โ”€โ”€โ”€โ”€โ”€โ”€โ”€โ”€โ”€โ”€โ”ฌโ”€โ”€โ”€โ”€โ”€โ”€โ”€โ”€โ”€โ”€โ”€โ”€โ”€โ”€โ”€โ”€โ”˜
                 โ”‚
                 โ–ผ
โ”Œโ”€โ”€โ”€โ”€โ”€โ”€โ”€โ”€โ”€โ”€โ”€โ”€โ”€โ”€โ”€โ”€โ”€โ”€โ”€โ”€โ”€โ”€โ”€โ”€โ”€โ”€โ”€โ”€โ”€โ”€โ”€โ”€โ”€โ”
โ”‚   โšก  Execution Agent           โ”‚
โ”‚   Run pipeline โ†’ Track progress  โ”‚
โ”‚   IN PROGRESS โ†’ REVIEW โ†’ DONE  โ”‚
โ””โ”€โ”€โ”€โ”€โ”€โ”€โ”€โ”€โ”€โ”€โ”€โ”€โ”€โ”€โ”€โ”€โ”ฌโ”€โ”€โ”€โ”€โ”€โ”€โ”€โ”€โ”€โ”€โ”€โ”€โ”€โ”€โ”€โ”€โ”˜
                 โ”‚
                 โ–ผ
       โœ…  Task Complete
       (Triggers unblock of dependent tasks)

Multi-Agent Swarm System

Step-by-step:

  1. Task Submitted โ€” A new task arrives via the REST API with title, description, tags, and optional dependencies
  2. Analysis โ€” The Task Analysis Agent parses the payload, assigns priority, and extracts metadata
  3. Dependency Check โ€” The Dependency Checker validates all prerequisite tasks. If any are incomplete, the task is held in a Blocked state
  4. Assignment โ€” Once clear, the Task Assignment Agent places the task into the Kanban board at the To Do column and transitions it to In Progress
  5. Execution โ€” The Execution Agent picks up the task, runs the workflow pipeline, and progresses the card through Review โ†’ Done
  6. Cascade โ€” Completing a task triggers the Dependency Checker to re-evaluate any tasks that were waiting on it โ€” unblocking the next batch automatically

๐Ÿ“ Project Structure

AI-Multi-Agent-Swarm-System/
โ”‚
โ”œโ”€โ”€ app.py                          # Flask app entry point & API routes
โ”œโ”€โ”€ requirements.txt                # All Python dependencies
โ”œโ”€โ”€ .env.example                    # Environment variable template
โ”œโ”€โ”€ README.md                       # Project documentation
โ”‚
โ”œโ”€โ”€ agents/
โ”‚   โ”œโ”€โ”€ analysis_agent.py           # Task Analysis Agent โ€” parse & prioritize
โ”‚   โ”œโ”€โ”€ dependency_agent.py         # Dependency Checker โ€” DAG validation
โ”‚   โ”œโ”€โ”€ assignment_agent.py         # Task Assignment โ€” Kanban placement
โ”‚   โ”œโ”€โ”€ execution_agent.py          # Execution Agent โ€” pipeline runner
โ”‚   โ””โ”€โ”€ base_agent.py               # Base agent class & shared utilities
โ”‚
โ”œโ”€โ”€ orchestrator/
โ”‚   โ”œโ”€โ”€ graph.py                    # LangGraph state graph definition
โ”‚   โ”œโ”€โ”€ state.py                    # Typed shared state schema
โ”‚   โ”œโ”€โ”€ router.py                   # Agent routing & transition logic
โ”‚   โ””โ”€โ”€ orchestrator.py             # Main orchestrator controller
โ”‚
โ”œโ”€โ”€ kanban/
โ”‚   โ”œโ”€โ”€ board.py                    # Kanban board state management
โ”‚   โ”œโ”€โ”€ columns.py                  # Column definitions & transition rules
โ”‚   โ””โ”€โ”€ task.py                     # Task model & lifecycle methods
โ”‚
โ”œโ”€โ”€ api/
โ”‚   โ”œโ”€โ”€ routes.py                   # Flask REST API route definitions
โ”‚   โ”œโ”€โ”€ schemas.py                  # Request/response validation schemas
โ”‚   โ””โ”€โ”€ middleware.py               # Auth, logging, error handling
โ”‚
โ”œโ”€โ”€ pipeline/
โ”‚   โ””โ”€โ”€ workflow.py                 # Workflow pipeline execution engine
โ”‚
โ”œโ”€โ”€ utils/
โ”‚   โ”œโ”€โ”€ logger.py                   # Structured audit logging
โ”‚   โ”œโ”€โ”€ config.py                   # Global configuration constants
โ”‚   โ””โ”€โ”€ helpers.py                  # Shared utility functions
โ”‚
โ”œโ”€โ”€ frontend/
โ”‚   โ”œโ”€โ”€ index.html                  # Kanban board dashboard
โ”‚   โ”œโ”€โ”€ board.js                    # Live board update logic
โ”‚   โ””โ”€โ”€ styles.css                  # Dashboard styling
โ”‚
โ””โ”€โ”€ tests/
    โ”œโ”€โ”€ test_agents.py              # Unit tests for each agent
    โ”œโ”€โ”€ test_orchestrator.py        # Integration tests for state graph
    โ””โ”€โ”€ test_api.py                 # REST API endpoint tests

โšก Quick Start

Prerequisites

Python 3.10 or higher
pip (Python package manager)

Installation

# 1. Clone the repository (search GitHub for "AI-Multi-Agent-Swarm-System" by Atharva Shevate)
cd AI-Multi-Agent-Swarm-System

# 2. Create & activate a virtual environment
python -m venv venv
source venv/bin/activate          # Linux / macOS
# venv\Scripts\activate           # Windows

# 3. Install all dependencies
pip install -r requirements.txt

# 4. Set up environment variables
cp .env.example .env
# Edit .env and add your API keys (OpenAI, Groq, etc.)

# 5. Run the application
python app.py

Once running, open http://localhost:5000 in your browser to view the live Kanban dashboard and start submitting tasks for the agents to process.

API Usage โ€” Submit a Task

# Submit a new task via REST API
curl -X POST http://localhost:5000/api/tasks \
  -H "Content-Type: application/json" \
  -d '{
    "title": "Build feature pipeline",
    "description": "Implement the data ingestion module",
    "priority": "high",
    "category": "engineering",
    "dependencies": ["task-001", "task-002"]
  }'

# Check task status
curl http://localhost:5000/api/tasks/{task_id}/status

# Get full Kanban board state
curl http://localhost:5000/api/board

Requirements File

langchain>=0.2.0
langgraph>=0.1.0
flask>=3.0.0
flask-cors>=4.0.0
python-dotenv>=1.0.0
pydantic>=2.0.0
openai>=1.0.0
requests>=2.31.0

๐Ÿ“Š Performance & Results

โ”โ”โ”โ”โ”โ”โ”โ”โ”โ”โ”โ”โ”โ”โ”โ”โ”โ”โ”โ”โ”โ”โ”โ”โ”โ”โ”โ”โ”โ”โ”โ”โ”โ”โ”โ”โ”โ”โ”โ”โ”โ”โ”โ”โ”โ”โ”โ”โ”โ”โ”โ”โ”โ”โ”โ”โ”
  Metric                          Result
โ”โ”โ”โ”โ”โ”โ”โ”โ”โ”โ”โ”โ”โ”โ”โ”โ”โ”โ”โ”โ”โ”โ”โ”โ”โ”โ”โ”โ”โ”โ”โ”โ”โ”โ”โ”โ”โ”โ”โ”โ”โ”โ”โ”โ”โ”โ”โ”โ”โ”โ”โ”โ”โ”โ”โ”โ”
  Task Assignment Accuracy        โœ…  High โ€” priority-aware routing
  Dependency Resolution           ๐Ÿ”—  Full DAG validation (multi-level)
  Kanban Sync Latency             โšก  Real-time board updates
  Agent Coordination              ๐Ÿค–  Zero-conflict shared state
  API Response Time               ๐ŸŒ  Fast REST endpoints (Flask)
  Audit Coverage                  ๐Ÿ“ˆ  100% โ€” every decision logged
  Concurrent Tasks Supported      โš™๏ธ  Multiple parallel pipelines
  Error Handling                  ๐Ÿ”’  Retry logic + state rollback
โ”โ”โ”โ”โ”โ”โ”โ”โ”โ”โ”โ”โ”โ”โ”โ”โ”โ”โ”โ”โ”โ”โ”โ”โ”โ”โ”โ”โ”โ”โ”โ”โ”โ”โ”โ”โ”โ”โ”โ”โ”โ”โ”โ”โ”โ”โ”โ”โ”โ”โ”โ”โ”โ”โ”โ”โ”

๐Ÿ† Project Highlights

  • โœ… True multi-agent collaboration โ€” not a single model, but a coordinated swarm of specialized agents
  • โœ… LangGraph-powered state machine โ€” type-safe shared state with well-defined agent transitions
  • โœ… Dependency-aware orchestration โ€” complex multi-level task dependency graphs resolved automatically
  • โœ… Live Kanban board โ€” full workflow visibility through a real-time visual dashboard
  • โœ… REST API integration โ€” Flask endpoints make the system easy to connect to any external tool
  • โœ… Audit-ready logging โ€” every agent decision recorded with full context and timestamps
  • โœ… Clean modular architecture โ€” each agent independently testable and replaceable without system downtime
  • โœ… Secure by design โ€” credentials isolated in .env, never committed to version control

๐Ÿ”’ Security Note

All API keys and credentials used by agents (LLM APIs, integrations, external services) must be stored in environment variables using a .env file. Never hard-code secrets into source files. Always add your .env, session folders, and config files to .gitignore before pushing to version control.

# .gitignore โ€” always include these
.env
*.key
config/secrets.json
venv/
__pycache__/

๐Ÿ”ฎ Future Enhancements

  • LLM-Powered Agents โ€” swap rule-based logic for GPT-4 / LLaMA 3 driven decision making
  • Analytics Dashboard โ€” task throughput, agent performance, and bottleneck visualization
  • Cloud Deployment โ€” deploy on AWS EC2 / Docker with auto-scaling agent pools
  • Predictive Task Allocation โ€” ML model predicts optimal agent assignment based on history
  • Real-Time Collaboration โ€” multi-user board with WebSocket live sync
  • Webhook Integration โ€” push events to Slack, Jira, or GitHub Issues on task completion
  • Agent Memory โ€” persistent vector store for agents to recall past decisions
  • Custom Agent Builder โ€” UI to define new specialist agents without code changes

๐Ÿ‘ค About the Author

Name Atharva Shevate
Role AI Engineer Intern @ IOTIOT.IN, Pune
University Vishwakarma University โ€” B.Tech Computer Engineering 2026
Specialization GenAI ยท LLMs ยท RAG ยท Multi-Agent Systems ยท Computer Vision
Email atharvshevate3@gmail.com
LinkedIn Atharva Shevate โ€” search "atharva-shevate" on LinkedIn
GitHub atharva1727
Portfolio Atharva Shevate's personal portfolio site

๐Ÿ“„ License

This project is licensed under the MIT License. See the LICENSE file included in the repository for full details.


โญ If you found this useful, consider starring the repo!

More projects, portfolio work, and contact details are available directly from Atharva Shevate โ€” GitHub: atharva1727 ย |ย  Email: atharvshevate3@gmail.com

"Building autonomous systems where agents collaborate like a team โ€” independently smart, collectively powerful." ๐Ÿค–

About

AI-powered multi-agent workflow automation system using Kanban-based task orchestration, dependency tracking, and intelligent agent collaboration.

Topics

Resources

Stars

3 stars

Watchers

0 watching

Forks

Releases

Packages

Contributors