Struct MultiExecutor 

pub struct MultiExecutor { /* private fields */ }

Multi-tool executor

Implementations

impl MultiExecutor

pub fn new(client: Arc<ComposioClient>) -> Self

Create a new multi-executor instance

Arguments

• client - Composio client instance

Example

use composio_sdk::{ComposioClient, meta_tools::MultiExecutor};
use std::sync::Arc;

let client = ComposioClient::builder()
    .api_key("your-api-key")
    .build()?;

let executor = MultiExecutor::new(Arc::new(client));

pub async fn execute_parallel( &self, session_id: &str, tools: Vec<ToolCall>, ) -> Result<MultiExecutionResult, ComposioError>

Execute multiple tools in parallel

Arguments

• session_id - Session ID for execution context
• tools - Vector of tool calls to execute (max 20)

Returns

Multi-execution result with individual results and statistics

Example

let executor = MultiExecutor::new(client);

let tools = vec![
    ToolCall {
        tool_slug: "GITHUB_GET_REPOS".to_string(),
        arguments: json!({ "owner": "composio" }),
        connected_account_id: None,
    },
    ToolCall {
        tool_slug: "GITHUB_GET_ISSUES".to_string(),
        arguments: json!({ "owner": "composio", "repo": "composio" }),
        connected_account_id: None,
    },
];

let result = executor.execute_parallel("session_123", tools).await?;
println!("Successful: {}, Failed: {}", result.successful, result.failed);

pub async fn execute_sequential( &self, session_id: &str, tools: Vec<ToolCall>, ) -> Result<MultiExecutionResult, ComposioError>

Execute tools sequentially (fallback for when parallel execution is not desired)

Arguments

• session_id - Session ID
• tools - Vector of tool calls

Example

let executor = MultiExecutor::new(client);

let tools = vec![
    ToolCall {
        tool_slug: "GITHUB_CREATE_ISSUE".to_string(),
        arguments: json!({ "title": "Bug", "body": "Description" }),
        connected_account_id: None,
    },
];

let result = executor.execute_sequential("session_123", tools).await?;