TriggerWorkflow​Trigger​Workflow

Trigger a n8n workflow via a webhook

This task allows you to execute n8n workflows from within Kestra by calling their webhook URLs. See the n8n Webhook Docs for more information on getting started with n8n Webhooks.

yaml
type: "io.kestra.plugin.n8n.webhook.TriggerWorkflow"

Simple Trigger Workflow

yaml
id: n8n_webhook_trigger
namespace: company.team

tasks:
  - id: trigger_workflow
    type: io.kestra.plugin.n8n.webhook.TriggerWorkflow
    method: POST
    uri: https://n8n.example.com/webhook/213e8fbc-f843-428c-9860-ab9f64e5ef3b

Trigger Workflow With Basic Auth

yaml
id: n8n_webhook_trigger_with_auth
namespace: company.team

tasks:
  - id: trigger_workflow
    type: io.kestra.plugin.n8n.webhook.TriggerWorkflow
    options:
      auth:
        type: BASIC
        username: "{{ secret('N8N_WEBHOOK_USERNAME') }}"
        password: "{{ secret('N8N_WEBHOOK_PASSWORD') }}"
    method: POST
    uri: https://n8n.example.com/webhook/213e8fbc-f843-428c-9860-ab9f64e5ef3b

Trigger Workflow With Body

yaml
id: n8n_webhook_trigger_with_body
namespace: company.team

tasks:
  - id: trigger_workflow
    type: io.kestra.plugin.n8n.webhook.TriggerWorkflow
    body:
      keyOne: valueOne
    method: POST
    uri: http://n8n:5678/webhook/213e8fbc-f843-428c-9860-ab9f64e5ef3b
Properties
Possible Values
GETPOSTPUTDELETEPATCH

HTTP Method

HTTP request method for the webhook call. n8n supports DELETE, GET, HEAD, PATCH, POST, and PUT methods. Choose the method that matches your n8n webhook configuration.

n8n webhook URL

The webhook URL endpoint from your n8n workflow. Use the Test URL for development or Production URL for live workflows.

Request Body

JSON data to send in the request body. Maximum payload size is 16MB. Use this for POST, PUT, or PATCH requests to send structured data to the n8n webhook.

Default BINARY
Possible Values
TEXTJSONXMLBINARY

Content Type

Format of the request body data. Choose BINARY for files, JSON for structured data, XML for XML documents, or TEXT for plain text content.

File Source URI

URI pointing to a file in Kestra storage to send as the request body. Use this instead of 'body' when sending binary data, files, or large content to the n8n webhook.

HTTP Headers

Custom HTTP headers to include with the webhook request. Headers are useful for authentication, content type specification, or passing additional metadata to the n8n workflow.

The HTTP client configuration.

Query Parameters

URL query parameters to append to the webhook URL. These parameters will be available in the n8n workflow as part of the incoming request data.

Default true

Wait for Response

Whether to wait for the n8n webhook response. When true, Kestra waits for the workflow to complete according to the response mode configured in n8n (immediate, deferred, or streaming).

Format duration

The time allowed to establish a connection to the server before failing.

Default PT5M
Format duration

The time allowed for a read connection to remain idle before closing it.

The password for HTTP basic authentication.

The username for HTTP basic authentication.

Default false

If true, allow a failed response code (response code >= 400)

SubType integer

List of response code allowed for this request

The authentification to use.

Default UTF-8

The default charset for the request.

Default true

Whether redirects should be followed automatically.

SubType string
Possible Values
REQUEST_HEADERSREQUEST_BODYRESPONSE_HEADERSRESPONSE_BODY

The enabled log.

The proxy configuration.

The SSL request options

The timeout configuration.

The address of the proxy server.

The password for proxy authentication.

The port of the proxy server.

Default DIRECT
Possible Values
DIRECTHTTPSOCKS

The type of proxy to use.

The username for proxy authentication.

Whether to disable checking of the remote SSL certificate.

Only applies if no trust store is configured. Note: This makes the SSL connection insecure and should only be used for testing. If you are using a self-signed certificate, set up a trust store instead.

The token for bearer token authentication.