Model Context Protocol (MCP) SSE client tool
yaml
type: "io.kestra.plugin.ai.tool.SseMcpClient"Examples
Agent calling an MCP server via SSE
yaml
id: mcp_client_sse
namespace: company.ai
inputs:
- id: prompt
type: STRING
defaults: Find 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.SseMcpClient
sseUrl: https://mcp.apify.com/?actors=compass/crawler-google-places
timeout: PT5M
headers:
Authorization: Bearer {{ kv('APIFY_API_TOKEN') }}Properties
sseUrl *Requiredstring
SSE URL of the MCP server
headers object
SubType string
Custom headers
Could be useful, for example, to add authentication tokens via the Authorization header.
logRequests booleanstring
Default
falseLog requests
logResponses booleanstring
Default
falseLog responses
timeout string
Format
durationConnection timeout duration