Temporal Trigger
CertifiedTrigger a Temporal workflow execution
Temporal Trigger
Trigger a Temporal workflow execution
Starts a new Temporal workflow and returns its workflow ID and run ID. If a workflow with the given ID is already running, the task fails with a clear error message.
type: io.kestra.plugin.temporal.workflow.TriggerExamples
Trigger an order-processing workflow on a local Temporal server.
id: trigger_order_workflow
namespace: company.team
tasks:
- id: start
type: io.kestra.plugin.temporal.workflow.Trigger
endpoint: "localhost:7233"
namespace: "default"
workflowType: "OrderWorkflow"
taskQueue: "order-queue"
workflowId: "order-{{ execution.id }}"
input:
- '{"orderId": "ORD-123", "amount": 99.99}'
executionTimeout: "PT1H"
Trigger a workflow on Temporal Cloud using an API key.
id: trigger_cloud_workflow
namespace: company.team
tasks:
- id: start
type: io.kestra.plugin.temporal.workflow.Trigger
endpoint: "myns.tmprl.cloud:7233"
namespace: "myns.accountId"
apiKey: "{{ secret('TEMPORAL_API_KEY') }}"
workflowType: "OrderWorkflow"
taskQueue: "order-queue"
Properties
endpoint *string
Temporal server endpoint
Host and port of the Temporal frontend service in host: port format.
For Temporal Cloud, use the gRPC endpoint for your namespace,
e.g. <namespace>.tmprl.cloud: 7233.
taskQueue *string
Task queue name
The worker polling this queue will pick up the workflow.
workflowType *string
Registered workflow type name
Must match the @WorkflowMethod implementation registered on the worker.
apiKey string
API key for Bearer token authentication
Used with Temporal Cloud. Sent as Authorization: Bearer <apiKey> on every
gRPC call; TLS is enabled automatically when this property is set.
Mutually exclusive with mTLS properties.
assets
Assets this task consumes as inputs or produces as outputs, for lineage tracking and the asset graph (Enterprise Edition). A flow declaring this property on a task is rejected in the open-source edition.
io.kestra.core.models.assets.AssetsDeclaration
IGNOREFAILWARNAsset failure behavior
Behavior applied to the task state when a declared asset fails to render, emit, or be persisted (e.g. a lock conflict): FAIL escalates it to FAILED, WARN (default) warns it if it would otherwise succeed, IGNORE leaves the state untouched.
Whether to auto-register assets referenced dynamically at runtime that are not statically declared in inputs or outputs.
The assets consumed as inputs.
io.kestra.core.models.assets.AssetIdentifier
1The assets produced as outputs.
io.kestra.plugin.ee.assets.Dataset
1150{}1150io.kestra.plugin.ee.assets.File
1150{}1150io.kestra.plugin.ee.assets.Table
1150{}1150io.kestra.plugin.ee.assets.VM
1150{}1150io.kestra.core.models.assets.External
1150{}1150io.kestra.core.models.assets.Custom
11501Custom asset type
{}1150caCert string
PEM-encoded CA certificate
Verifies the server certificate. Can be used alone for one-way TLS
with a custom CA, or together with clientCert/clientKey for mTLS.
clientCert string
PEM-encoded client certificate
Used in mTLS mode. Must be provided together with clientKey.
clientKey string
PEM-encoded client private key
Used in mTLS mode. Must be provided together with clientCert.
executionTimeout string
Maximum time allowed for the workflow to complete
ISO-8601 duration, e.g. PT1H for one hour.
input array
Workflow input arguments
List of JSON-encoded argument strings, one per workflow parameter.
Example: ["{"key": "value"}", "42"]
namespace string
Temporal namespace
Defaults to default. For Temporal Cloud, typically <namespace>.<accountId>.
workflowId string
Workflow ID
Optional. A UUID is generated when absent.
Outputs
runId string
Run ID
The unique run ID assigned by Temporal to this execution.
workflowId string
Workflow ID
The ID of the started workflow execution.
