Model Context Protocol (MCP) SSE client tool
yaml
type: "io.kestra.plugin.ai.tool.StreamableHttpMcpClient"Examples
Agent calling an MCP server via SSE
yaml
id: mcp_client_sse
namespace: company.ai
inputs:
  - id: prompt
    type: STRING
    defaults: Find the 2 restaurants in Lille, France with the best reviews.
tasks:
  - id: agent
    type: io.kestra.plugin.ai.agent.AIAgent
    prompt: "{{inputs.prompt}}"
    provider:
      type: io.kestra.plugin.ai.provider.GoogleGemini
      modelName: gemini-2.5-flash
      apiKey: "{{ kv('GEMINI_API_KEY') }}"
    tools:
      - type: io.kestra.plugin.ai.tool.StreamableHttpMcpClient
        url: https://mcp.apify.com/?actors=compass/crawler-google-places
        timeout: PT5M
        headers:
          Authorization: Bearer {{ kv('APIFY_API_TOKEN') }}Properties
url *Requiredstring
URL of the MCP server
headers object
 SubType string
Custom headers
Useful, for example, for adding authentication tokens via the Authorization header.
logRequests booleanstring
 Default 
falseLog requests
logResponses booleanstring
 Default 
falseLog responses
timeout string
 Format 
durationConnection timeout duration
