XExecution
Send an X (Twitter) post with execution information.

Send an X (Twitter) post with execution information.

Send execution details via X (Twitter) including execution link, ID, namespace, flow name, start date, duration, and status.

yaml
type: "io.kestra.plugin.notifications.x.XExecution"

Examples

Send an X notification on a failed flow execution using Bearer Token.

yaml
id: failure_alert_x
namespace: company.team

tasks:
  - id: send_x_alert
    type: io.kestra.plugin.notifications.x.XExecution
    bearerToken: "{{ secret('X_BEARER_TOKEN') }}"
    executionId: "{{ trigger.executionId }}"
    customMessage: "Production workflow failed - immediate attention required!"
    customFields:
      Environment: "Production"
      Team: "DevOps"
      Priority: "High"

triggers:
  - id: failed_prod_workflows
    type: io.kestra.plugin.core.trigger.Flow
    conditions:
      - type: io.kestra.plugin.core.condition.ExecutionStatus
        in:
          - FAILED
          - WARNING
      - type: io.kestra.plugin.core.condition.ExecutionNamespace
        namespace: prod
        prefix: true

Send an X notification using OAuth 1.0a credentials.

yaml
id: success_alert_x
namespace: company.team

tasks:
  - id: send_x_success
    type: io.kestra.plugin.notifications.x.XExecution
    consumerKey: "{{ secret('X_CONSUMER_KEY') }}"
    consumerSecret: "{{ secret('X_CONSUMER_SECRET') }}"
    accessToken: "{{ secret('X_ACCESS_TOKEN') }}"
    accessSecret: "{{ secret('X_ACCESS_SECRET') }}"
    executionId: "{{ trigger.executionId }}"
    customMessage: "Deployment completed successfully!"

triggers:
  - id: successful_deployments
    type: io.kestra.plugin.core.trigger.Flow
    conditions:
      - type: io.kestra.plugin.core.condition.ExecutionStatus
        in:
          - SUCCESS

Properties

accessSecretstring

OAuth Access Secret

X API OAuth 1.0a Access Token Secret. Required if bearerToken is not provided.

accessTokenstring

OAuth Access Token

X API OAuth 1.0a Access Token. Required if bearerToken is not provided.

bearerTokenstring

Bearer Token

X API Bearer Token for authentication. If provided, OAuth 1.0a credentials are not required.

consumerKeystring

OAuth Consumer Key

X API OAuth 1.0a Consumer Key (API Key). Required if bearerToken is not provided.

consumerSecretstring

OAuth Consumer Secret

X API OAuth 1.0a Consumer Secret (API Secret). Required if bearerToken is not provided.

customFieldsobject

Custom fields to be added in the notification

customMessagestring

Custom message to be added in the notification

executionIdstring

Default{{ execution.id }}

The execution ID to use

Default is the current execution, change it to if you use this task with a Flow trigger to use the original execution.

options

Options

The options to set to customize the HTTP client

Definitions

io.kestra.plugin.notifications.AbstractHttpOptionsTask-RequestOptions

connectTimeoutstring

Formatduration

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

connectionPoolIdleTimeoutstring

DefaultPT0S

Formatduration

The time an idle connection can remain in the client's connection pool before being closed.

defaultCharsetstring

DefaultUTF-8

The default charset for the request.

java.nio.charset.Charset

headersobject

SubTypestring

HTTP headers

HTTP headers to include in the request

maxContentLengthintegerstring

Default10485760

The maximum content length of the response.

readIdleTimeoutstring

DefaultPT5M

Formatduration

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

readTimeoutstring

DefaultPT10S

Formatduration

The maximum time allowed for reading data from the server before failing.

templateRenderMapobject

Map of variables to use for the message template

textBodystring

Post text body

Direct post text (bypasses template)

urlstring

Defaulthttps://api.x.com/2/tweets

Override URL for testing

Optional URL to override the default X API endpoint (for testing purposes)

Azure

Enterprise

Leverage Microsoft Azure services within Kestra data workflows.

AlertingCloudStorageBatch

ServiceNow

This sub-group of plugins contains tasks for using ServiceNow. ServiceNow allows employees to work the way they want to, not how software dictates they have to.

Alerting