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