Skip to main content

Mainframe-Orchestra is a lightweight, open-source agentic framework for building LLM based pipelines and self-orchestrating multi-agent teams

Project description

PRs Welcome PyPI version License Twitter

Orchestra

Cognitive Architectures for Multi-Agent Teams.

Table of Contents

Overview

Mainframe-Orchestra is a lightweight, open-source agentic framework for building LLM-based pipelines and multi-agent teams. It implements a unique approach to agent orchestration that goes beyond simple routing, enabling complex workflows.

Key Features

  • Modularity: Modular architecture for easy building, extension, and integration
  • Agent Orchestration: Agents can act as both executors and conductors, enabling dynamic task decomposition and coordination among agents
  • Phased Task Execution: Reduces cognitive load on LLMs through structured thinking patterns
  • Tool Integration: Simple docstring-based tool definitions without complex JSON schemas
  • Streaming Support: Real-time output streaming with both sync and async support
  • Built-in Fallbacks: Graceful handling of LLM failures with configurable fallback chains

Installation

Install Orchestra using pip:

pip install mainframe-orchestra

Quick Start

Here's a simple example to get you started:

from mainframe_orchestra import Agent, Task, OpenaiModels, WebTools, set_verbosity

set_verbosity(1)

research_agent = Agent(
    agent_id="research_assistant_1",
    role="research assistant",
    goal="answer user queries",
    llm=OpenaiModels.gpt_4o,
    tools={WebTools.exa_search}
)

def research_task(topic):
    return Task.create(
        agent=research_agent,
        instruction=f"Use your exa search tool to research {topic} and explain it in a way that is easy to understand.",
    )

result = research_task("quantum computing")
print(result)

Core Components

Tasks: Discrete units of work

Agents: Personas that perform tasks and can be assigned tools

Tools: Wrappers around external services or specific functionalities

Language Model Interfaces: Consistent interface for various LLM providers

Supported Language Models and Providers

Orchestra supports a wide range of language models from a number of providers:

OpenAI

GPT-4.5-preview, GPT-4o, GPT-4o Mini, & Custom defined models

Anthropic

Claude 3 Haiku, Claude 3 Sonnet, Claude 3 Opus, Claude 3.5 Sonnet, Claude 3.7 Sonnet, & Custom defined models

Openrouter

GPT-4 Turbo, Claude 3 Opus, Mixtral 8x7B, Llama 3.1 405B, & Custom defined models

Ollama

Mistral, Mixtral, Llama 3.1, Qwen, Gemma, & Custom defined models

Groq

Mixtral 8x7B, Llama 3, Llama 3.1, Gemma, & Custom defined models

TogetherAI

Custom defined models

Gemini

Gemini 1.5 Flash, Gemini 1.5 Flash 8B, Gemini 1.5 Pro, & Custom defined models

Deepseek

Deepseek Reasoner, Deepseek Chat, & Custom defined models

Each provider is accessible through a dedicated class (e.g., OpenaiModels, AnthropicModels, etc.) with methods corresponding to specific models. This structure allows for painless switching between models and providers, enabling users to leverage the most suitable LLM for their tasks.

Tools

Mainframe-Orchestra comes with a comprehensive set of built-in tools that provide various functionalities for your agents. Here's an overview of the available tool categories:

Built-in Tools

Data & File Operations

  • FileTools: Read and write CSV, JSON, XML, and other file formats
  • TextSplitters: Tools for chunking and splitting text documents
  • EmbeddingsTools: Generate embeddings for text content
  • FaissTools: Vector storage and similarity search operations
  • PineconeTools: Vector database operations with Pinecone

Web & API Integration

  • WebTools: Web scraping, searches, and data retrieval (Serper, Exa, etc.)
  • WikipediaTools: Search and retrieve Wikipedia content
  • AmadeusTools: Flight information and travel data
  • GitHubTools: GitHub repository operations and content access
  • LinearTools: Linear API-based tools for creating, updating, and retrieving tasks

Financial & Data Analysis

  • YahooFinanceTools: Stock market data and financial analysis
  • FredTools: Federal Reserve Economic Data access
  • CalculatorTools: Date, time, and mathematical calculations
  • MatplotlibTools: Data visualization and plotting

Media & Content

  • AudioTools: Audio processing and manipulation
  • TextToSpeechTools: Text-to-speech conversion using ElevenLabs and OpenAI APIs
  • WhisperTools: Audio transcription and translation using OpenAI's Whisper API

Integration Tools

  • LangchainTools: Wrapper for accessing the Langchain tools ecosystem

Custom Tools

Mainframe-Orchestra supports creating custom tools to extend functionality beyond the built-in tools. Custom tools can be implemented either as static methods or as class instance methods for more complex operations. Here's a basic example:

import numpy as np
from typing import List, Union

class NumpyTools:
    @staticmethod
    def array_mean(arr: Union[List[float], np.ndarray]) -> Union[float, str]:
        """
        Calculate the mean of a given array.

        Args:
            arr (Union[List[float], np.ndarray]): Input array or list of numbers.

        Returns:
            Union[float, str]: The mean of the input array as a float, or an error message as a string.
        """
        try:
            arr = np.array(arr, dtype=float)
            if arr.size == 0:
                return "Error: Input array is empty."
            return float(np.mean(arr))
        except TypeError as e:
            return f"Error: Invalid input type. Expected a list or numpy array of numbers. Details: {e}"
        except Exception as e:
            return f"Error: An unexpected error occurred: {e}"

Tools can be assigned to agents during initialization:

agent = Agent(
    agent_id="my_agent",
    tools={NumpyTools.array_mean, WebTools.exa_search}
)

For detailed documentation on creating custom tools, including best practices for error handling and API integration, visit our Custom Tools Documentation.

Multi-Agent Teams

Mainframe-Orchestra allows you to create multi-agent teams that can use tools to complete a series of tasks. Here's an example of a finance agent that uses multiple agents to analyze a stock:

from mainframe_orchestra import Task, Agent, Conduct, OpenaiModels, WebTools, YahooFinanceTools

# Create specialized agents
market_analyst = Agent(
    agent_id="market_analyst",
    role="Market Microstructure Analyst",
    goal="Analyze market microstructure and identify trading opportunities",
    attributes="You have expertise in market microstructure, order flow analysis, and high-frequency data.",
    llm=OpenaiModels.gpt_4o,
    tools={YahooFinanceTools.calculate_returns, YahooFinanceTools.get_historical_data}
)

fundamental_analyst = Agent(
    agent_id="fundamental_analyst",
    role="Fundamental Analyst",
    goal="Analyze company financials and assess intrinsic value",
    attributes="You have expertise in financial statement analysis, valuation models, and industry analysis.",
    llm=OpenaiModels.gpt_4o,
    tools={YahooFinanceTools.get_financials, YahooFinanceTools.get_ticker_info}
)

technical_analyst = Agent(
    agent_id="technical_analyst",
    role="Technical Analyst",
    goal="Analyze price charts and identify trading patterns",
    attributes="You have expertise in technical analysis, chart patterns, and technical indicators.",
    llm=OpenaiModels.gpt_4o,
    tools={YahooFinanceTools.get_historical_data}
)

sentiment_analyst = Agent(
    agent_id="sentiment_analyst",
    role="Sentiment Analyst",
    goal="Analyze market sentiment, analyst recommendations and news trends",
    attributes="You have expertise in market sentiment analysis.",
    llm=OpenaiModels.gpt_4o,
    tools={YahooFinanceTools.get_recommendations, WebTools.serper_search}
)

conductor_agent = Agent(
    agent_id="conductor_agent",
    role="Conductor",
    goal="Conduct the orchestra",
    attributes="You have expertise in orchestrating the agents in your team.",
    llm=OpenaiModels.gpt_4o,
    tools=[Conduct.conduct_tool(market_analyst, fundamental_analyst, technical_analyst, sentiment_analyst)]
)

def chat_task(conversation_history, userinput):
    return Task.create(
        agent=conductor_agent,
        messages=conversation_history,
        instruction=userinput
    )

def main():
    conversation_history = []
    while True:
        userinput = input("You: ")
        conversation_history.append({"role": "user", "content": userinput})
        response = chat_task(conversation_history, userinput)
        conversation_history.append({"role": "assistant", "content": response})
        print(f"Market Analyst: {response}")

if __name__ == "__main__":
    main()

Note: this example requires the yahoofinance and yfinance packages to be installed. You can install them with pip install yahoofinance yfinance.

Conduct and Compose

The Conduct and Compose tools are used to orchestrate and compose agents. Conduct is used to actually instruct and orchestrate a team of agents, while Compose is used in addition to the Conduct tool to enrich the orchestration process with additional complexity as a preprocessing step. It's important to note that Conduct is required for the orchestration process to work, while Compose is an optional additional tool that can be used to enrich the orchestration process.

By combining agents, tasks, tools, and language models, you can create a wide range of workflows, from simple pipelines to complex multi-agent teams.

Documentation

For more detailed information, tutorials, and advanced usage, visit our documentation.

Contributing

Mainframe-Orchestra depends on and welcomes community contributions! Please review contribution guidelines and submit a pull request if you'd like to contribute.

License

Mainframe-Orchestra is released under the Apache License 2.0. See the LICENSE file for details.

Acknowledgments

Orchestra is a fork and further development of TaskflowAI.

Support

For issues or questions, please file an issue on our GitHub repository issues page.

⭐️ If you find Mainframe-Orchestra helpful, consider giving it a star!

Happy building!

Project details


Download files

Download the file for your platform. If you're not sure which to choose, learn more about installing packages.

Source Distribution

mainframe_orchestra-0.0.25.tar.gz (78.9 kB view details)

Uploaded Source

Built Distribution

If you're not sure about the file name format, learn more about wheel file names.

mainframe_orchestra-0.0.25-py3-none-any.whl (89.5 kB view details)

Uploaded Python 3

File details

Details for the file mainframe_orchestra-0.0.25.tar.gz.

File metadata

  • Download URL: mainframe_orchestra-0.0.25.tar.gz
  • Upload date:
  • Size: 78.9 kB
  • Tags: Source
  • Uploaded using Trusted Publishing? No
  • Uploaded via: poetry/2.1.1 CPython/3.13.2 Linux/6.8.0-1021-azure

File hashes

Hashes for mainframe_orchestra-0.0.25.tar.gz
Algorithm Hash digest
SHA256 19e6fa7181ba34f2efa22857ee096ed9199f0b5efcef381c1e4086c03c24f0dc
MD5 a4b772a6b0b79f637d9f143b56346cf6
BLAKE2b-256 d7cb450621596313c2090e3f3e593b6dcb2187efc8bf5ae8b07ecaf5f29b821c

See more details on using hashes here.

File details

Details for the file mainframe_orchestra-0.0.25-py3-none-any.whl.

File metadata

  • Download URL: mainframe_orchestra-0.0.25-py3-none-any.whl
  • Upload date:
  • Size: 89.5 kB
  • Tags: Python 3
  • Uploaded using Trusted Publishing? No
  • Uploaded via: poetry/2.1.1 CPython/3.13.2 Linux/6.8.0-1021-azure

File hashes

Hashes for mainframe_orchestra-0.0.25-py3-none-any.whl
Algorithm Hash digest
SHA256 3f116c10a9d5403a7f513fe0ca932c7507dd78620e09b3a422a7f6477ad24c99
MD5 8f073f43777d2cd134b02e3bcd911e1f
BLAKE2b-256 2a0f63ef464ea7740ce4678ee45f9dfa93703e4bd35046e65c8744d2d49e5a1b

See more details on using hashes here.

Supported by

AWS Cloud computing and Security Sponsor Datadog Monitoring Depot Continuous Integration Fastly CDN Google Download Analytics Pingdom Monitoring Sentry Error logging StatusPage Status page