curl --request POST \
--url https://flows.super.ai/api/task-executions \
--header 'Authorization: Bearer <token>' \
--header 'Content-Type: application/json' \
--data '
{
"flow_execution_id": "123e4567-e89b-12d3-a456-426614174000",
"processing_status": "running",
"task_execution_idx": 0,
"task_name": "send_email",
"completed_at": "2023-11-07T05:31:56Z",
"error": {
"message": "Connection timeout after 30s",
"traceback": "...",
"type": "ConnectionError"
},
"input": {
"recipient": "user@example.com",
"subject": "Hello"
},
"output": {
"email_id": "msg_123",
"sent_at": "2025-01-23T10:30:00Z"
},
"source_task_executions": "<unknown>",
"started_at": "2023-11-07T05:31:56Z",
"usage": {
"task_executor_name": "doc_to_structured",
"usage_metadata": {}
}
}
'import requests
url = "https://flows.super.ai/api/task-executions"
payload = {
"flow_execution_id": "123e4567-e89b-12d3-a456-426614174000",
"processing_status": "running",
"task_execution_idx": 0,
"task_name": "send_email",
"completed_at": "2023-11-07T05:31:56Z",
"error": {
"message": "Connection timeout after 30s",
"traceback": "...",
"type": "ConnectionError"
},
"input": {
"recipient": "user@example.com",
"subject": "Hello"
},
"output": {
"email_id": "msg_123",
"sent_at": "2025-01-23T10:30:00Z"
},
"source_task_executions": "<unknown>",
"started_at": "2023-11-07T05:31:56Z",
"usage": {
"task_executor_name": "doc_to_structured",
"usage_metadata": {}
}
}
headers = {
"Authorization": "Bearer <token>",
"Content-Type": "application/json"
}
response = requests.post(url, json=payload, headers=headers)
print(response.text)const options = {
method: 'POST',
headers: {Authorization: 'Bearer <token>', 'Content-Type': 'application/json'},
body: JSON.stringify({
flow_execution_id: '123e4567-e89b-12d3-a456-426614174000',
processing_status: 'running',
task_execution_idx: 0,
task_name: 'send_email',
completed_at: '2023-11-07T05:31:56Z',
error: {
message: 'Connection timeout after 30s',
traceback: '...',
type: 'ConnectionError'
},
input: {recipient: 'user@example.com', subject: 'Hello'},
output: {email_id: 'msg_123', sent_at: '2025-01-23T10:30:00Z'},
source_task_executions: '<unknown>',
started_at: '2023-11-07T05:31:56Z',
usage: {task_executor_name: 'doc_to_structured', usage_metadata: {}}
})
};
fetch('https://flows.super.ai/api/task-executions', options)
.then(res => res.json())
.then(res => console.log(res))
.catch(err => console.error(err));<?php
$curl = curl_init();
curl_setopt_array($curl, [
CURLOPT_URL => "https://flows.super.ai/api/task-executions",
CURLOPT_RETURNTRANSFER => true,
CURLOPT_ENCODING => "",
CURLOPT_MAXREDIRS => 10,
CURLOPT_TIMEOUT => 30,
CURLOPT_HTTP_VERSION => CURL_HTTP_VERSION_1_1,
CURLOPT_CUSTOMREQUEST => "POST",
CURLOPT_POSTFIELDS => json_encode([
'flow_execution_id' => '123e4567-e89b-12d3-a456-426614174000',
'processing_status' => 'running',
'task_execution_idx' => 0,
'task_name' => 'send_email',
'completed_at' => '2023-11-07T05:31:56Z',
'error' => [
'message' => 'Connection timeout after 30s',
'traceback' => '...',
'type' => 'ConnectionError'
],
'input' => [
'recipient' => 'user@example.com',
'subject' => 'Hello'
],
'output' => [
'email_id' => 'msg_123',
'sent_at' => '2025-01-23T10:30:00Z'
],
'source_task_executions' => '<unknown>',
'started_at' => '2023-11-07T05:31:56Z',
'usage' => [
'task_executor_name' => 'doc_to_structured',
'usage_metadata' => [
]
]
]),
CURLOPT_HTTPHEADER => [
"Authorization: Bearer <token>",
"Content-Type: application/json"
],
]);
$response = curl_exec($curl);
$err = curl_error($curl);
curl_close($curl);
if ($err) {
echo "cURL Error #:" . $err;
} else {
echo $response;
}package main
import (
"fmt"
"strings"
"net/http"
"io"
)
func main() {
url := "https://flows.super.ai/api/task-executions"
payload := strings.NewReader("{\n \"flow_execution_id\": \"123e4567-e89b-12d3-a456-426614174000\",\n \"processing_status\": \"running\",\n \"task_execution_idx\": 0,\n \"task_name\": \"send_email\",\n \"completed_at\": \"2023-11-07T05:31:56Z\",\n \"error\": {\n \"message\": \"Connection timeout after 30s\",\n \"traceback\": \"...\",\n \"type\": \"ConnectionError\"\n },\n \"input\": {\n \"recipient\": \"user@example.com\",\n \"subject\": \"Hello\"\n },\n \"output\": {\n \"email_id\": \"msg_123\",\n \"sent_at\": \"2025-01-23T10:30:00Z\"\n },\n \"source_task_executions\": \"<unknown>\",\n \"started_at\": \"2023-11-07T05:31:56Z\",\n \"usage\": {\n \"task_executor_name\": \"doc_to_structured\",\n \"usage_metadata\": {}\n }\n}")
req, _ := http.NewRequest("POST", url, payload)
req.Header.Add("Authorization", "Bearer <token>")
req.Header.Add("Content-Type", "application/json")
res, _ := http.DefaultClient.Do(req)
defer res.Body.Close()
body, _ := io.ReadAll(res.Body)
fmt.Println(string(body))
}HttpResponse<String> response = Unirest.post("https://flows.super.ai/api/task-executions")
.header("Authorization", "Bearer <token>")
.header("Content-Type", "application/json")
.body("{\n \"flow_execution_id\": \"123e4567-e89b-12d3-a456-426614174000\",\n \"processing_status\": \"running\",\n \"task_execution_idx\": 0,\n \"task_name\": \"send_email\",\n \"completed_at\": \"2023-11-07T05:31:56Z\",\n \"error\": {\n \"message\": \"Connection timeout after 30s\",\n \"traceback\": \"...\",\n \"type\": \"ConnectionError\"\n },\n \"input\": {\n \"recipient\": \"user@example.com\",\n \"subject\": \"Hello\"\n },\n \"output\": {\n \"email_id\": \"msg_123\",\n \"sent_at\": \"2025-01-23T10:30:00Z\"\n },\n \"source_task_executions\": \"<unknown>\",\n \"started_at\": \"2023-11-07T05:31:56Z\",\n \"usage\": {\n \"task_executor_name\": \"doc_to_structured\",\n \"usage_metadata\": {}\n }\n}")
.asString();require 'uri'
require 'net/http'
url = URI("https://flows.super.ai/api/task-executions")
http = Net::HTTP.new(url.host, url.port)
http.use_ssl = true
request = Net::HTTP::Post.new(url)
request["Authorization"] = 'Bearer <token>'
request["Content-Type"] = 'application/json'
request.body = "{\n \"flow_execution_id\": \"123e4567-e89b-12d3-a456-426614174000\",\n \"processing_status\": \"running\",\n \"task_execution_idx\": 0,\n \"task_name\": \"send_email\",\n \"completed_at\": \"2023-11-07T05:31:56Z\",\n \"error\": {\n \"message\": \"Connection timeout after 30s\",\n \"traceback\": \"...\",\n \"type\": \"ConnectionError\"\n },\n \"input\": {\n \"recipient\": \"user@example.com\",\n \"subject\": \"Hello\"\n },\n \"output\": {\n \"email_id\": \"msg_123\",\n \"sent_at\": \"2025-01-23T10:30:00Z\"\n },\n \"source_task_executions\": \"<unknown>\",\n \"started_at\": \"2023-11-07T05:31:56Z\",\n \"usage\": {\n \"task_executor_name\": \"doc_to_structured\",\n \"usage_metadata\": {}\n }\n}"
response = http.request(request)
puts response.read_body{
"edited_status": "not_edited",
"flow_execution_id": "223e4567-e89b-12d3-a456-426614174000",
"id": "123e4567-e89b-12d3-a456-426614174000",
"organization_id": "323e4567-e89b-12d3-a456-426614174000",
"processing_status": "queued",
"stale_status": "consistent",
"task_execution_idx": 0,
"task_name": "send_email",
"completed_at": "2023-11-07T05:31:56Z",
"created_at": "2025-01-23T10:30:00Z",
"credits": 10,
"error": {
"message": "Connection timeout after 30 seconds",
"traceback": "Traceback (most recent call last):\n ...",
"type": "ConnectionError"
},
"input": {
"recipient": "user@example.com",
"subject": "Hello"
},
"modified_by": "system",
"output": {
"email_id": "msg_123",
"sent_at": "2025-01-23T10:30:00Z"
},
"source_task_executions": "<unknown>",
"started_at": "2023-11-07T05:31:56Z",
"updated_at": "2025-01-23T10:35:00Z",
"usage_recorded": true
}Create a task execution record
Create a new task execution record for a specific task within a flow execution.
Overview Task executions represent individual task invocations within a flow execution. Each task in a flow can be executed multiple times (retries, loops), tracked by task_execution_idx. This endpoint is primarily used by system workers to report task execution state.
Resource Hierarchy Organization → Flow → Flow Execution → Task Execution
Lifecycle Task executions progress through states: queued → running → completed/failed
- queued: Task scheduled but not yet started
- running: Task currently executing
- completed: Task finished successfully with output
- failed: Task encountered an error
Use Cases
- Workers reporting task execution start/completion
- Recording task outputs for downstream tasks
- Tracking task execution history and retries
- Debugging failed workflow executions
Idempotency This endpoint is idempotent based on (flow_execution_id, task_name, task_execution_idx). If a task execution with these identifiers exists, it will be updated rather than creating a duplicate.
Performance Notes WebSocket notifications are processed in the background to ensure fast worker responses. The endpoint returns immediately after database write; notifications are async.
Related Endpoints
- GET /task-executions - List task executions with filtering
- PUT /task-executions - Update existing task execution and optionally re-execute flow
- GET /flow-executions/ - View parent flow execution
curl --request POST \
--url https://flows.super.ai/api/task-executions \
--header 'Authorization: Bearer <token>' \
--header 'Content-Type: application/json' \
--data '
{
"flow_execution_id": "123e4567-e89b-12d3-a456-426614174000",
"processing_status": "running",
"task_execution_idx": 0,
"task_name": "send_email",
"completed_at": "2023-11-07T05:31:56Z",
"error": {
"message": "Connection timeout after 30s",
"traceback": "...",
"type": "ConnectionError"
},
"input": {
"recipient": "user@example.com",
"subject": "Hello"
},
"output": {
"email_id": "msg_123",
"sent_at": "2025-01-23T10:30:00Z"
},
"source_task_executions": "<unknown>",
"started_at": "2023-11-07T05:31:56Z",
"usage": {
"task_executor_name": "doc_to_structured",
"usage_metadata": {}
}
}
'import requests
url = "https://flows.super.ai/api/task-executions"
payload = {
"flow_execution_id": "123e4567-e89b-12d3-a456-426614174000",
"processing_status": "running",
"task_execution_idx": 0,
"task_name": "send_email",
"completed_at": "2023-11-07T05:31:56Z",
"error": {
"message": "Connection timeout after 30s",
"traceback": "...",
"type": "ConnectionError"
},
"input": {
"recipient": "user@example.com",
"subject": "Hello"
},
"output": {
"email_id": "msg_123",
"sent_at": "2025-01-23T10:30:00Z"
},
"source_task_executions": "<unknown>",
"started_at": "2023-11-07T05:31:56Z",
"usage": {
"task_executor_name": "doc_to_structured",
"usage_metadata": {}
}
}
headers = {
"Authorization": "Bearer <token>",
"Content-Type": "application/json"
}
response = requests.post(url, json=payload, headers=headers)
print(response.text)const options = {
method: 'POST',
headers: {Authorization: 'Bearer <token>', 'Content-Type': 'application/json'},
body: JSON.stringify({
flow_execution_id: '123e4567-e89b-12d3-a456-426614174000',
processing_status: 'running',
task_execution_idx: 0,
task_name: 'send_email',
completed_at: '2023-11-07T05:31:56Z',
error: {
message: 'Connection timeout after 30s',
traceback: '...',
type: 'ConnectionError'
},
input: {recipient: 'user@example.com', subject: 'Hello'},
output: {email_id: 'msg_123', sent_at: '2025-01-23T10:30:00Z'},
source_task_executions: '<unknown>',
started_at: '2023-11-07T05:31:56Z',
usage: {task_executor_name: 'doc_to_structured', usage_metadata: {}}
})
};
fetch('https://flows.super.ai/api/task-executions', options)
.then(res => res.json())
.then(res => console.log(res))
.catch(err => console.error(err));<?php
$curl = curl_init();
curl_setopt_array($curl, [
CURLOPT_URL => "https://flows.super.ai/api/task-executions",
CURLOPT_RETURNTRANSFER => true,
CURLOPT_ENCODING => "",
CURLOPT_MAXREDIRS => 10,
CURLOPT_TIMEOUT => 30,
CURLOPT_HTTP_VERSION => CURL_HTTP_VERSION_1_1,
CURLOPT_CUSTOMREQUEST => "POST",
CURLOPT_POSTFIELDS => json_encode([
'flow_execution_id' => '123e4567-e89b-12d3-a456-426614174000',
'processing_status' => 'running',
'task_execution_idx' => 0,
'task_name' => 'send_email',
'completed_at' => '2023-11-07T05:31:56Z',
'error' => [
'message' => 'Connection timeout after 30s',
'traceback' => '...',
'type' => 'ConnectionError'
],
'input' => [
'recipient' => 'user@example.com',
'subject' => 'Hello'
],
'output' => [
'email_id' => 'msg_123',
'sent_at' => '2025-01-23T10:30:00Z'
],
'source_task_executions' => '<unknown>',
'started_at' => '2023-11-07T05:31:56Z',
'usage' => [
'task_executor_name' => 'doc_to_structured',
'usage_metadata' => [
]
]
]),
CURLOPT_HTTPHEADER => [
"Authorization: Bearer <token>",
"Content-Type: application/json"
],
]);
$response = curl_exec($curl);
$err = curl_error($curl);
curl_close($curl);
if ($err) {
echo "cURL Error #:" . $err;
} else {
echo $response;
}package main
import (
"fmt"
"strings"
"net/http"
"io"
)
func main() {
url := "https://flows.super.ai/api/task-executions"
payload := strings.NewReader("{\n \"flow_execution_id\": \"123e4567-e89b-12d3-a456-426614174000\",\n \"processing_status\": \"running\",\n \"task_execution_idx\": 0,\n \"task_name\": \"send_email\",\n \"completed_at\": \"2023-11-07T05:31:56Z\",\n \"error\": {\n \"message\": \"Connection timeout after 30s\",\n \"traceback\": \"...\",\n \"type\": \"ConnectionError\"\n },\n \"input\": {\n \"recipient\": \"user@example.com\",\n \"subject\": \"Hello\"\n },\n \"output\": {\n \"email_id\": \"msg_123\",\n \"sent_at\": \"2025-01-23T10:30:00Z\"\n },\n \"source_task_executions\": \"<unknown>\",\n \"started_at\": \"2023-11-07T05:31:56Z\",\n \"usage\": {\n \"task_executor_name\": \"doc_to_structured\",\n \"usage_metadata\": {}\n }\n}")
req, _ := http.NewRequest("POST", url, payload)
req.Header.Add("Authorization", "Bearer <token>")
req.Header.Add("Content-Type", "application/json")
res, _ := http.DefaultClient.Do(req)
defer res.Body.Close()
body, _ := io.ReadAll(res.Body)
fmt.Println(string(body))
}HttpResponse<String> response = Unirest.post("https://flows.super.ai/api/task-executions")
.header("Authorization", "Bearer <token>")
.header("Content-Type", "application/json")
.body("{\n \"flow_execution_id\": \"123e4567-e89b-12d3-a456-426614174000\",\n \"processing_status\": \"running\",\n \"task_execution_idx\": 0,\n \"task_name\": \"send_email\",\n \"completed_at\": \"2023-11-07T05:31:56Z\",\n \"error\": {\n \"message\": \"Connection timeout after 30s\",\n \"traceback\": \"...\",\n \"type\": \"ConnectionError\"\n },\n \"input\": {\n \"recipient\": \"user@example.com\",\n \"subject\": \"Hello\"\n },\n \"output\": {\n \"email_id\": \"msg_123\",\n \"sent_at\": \"2025-01-23T10:30:00Z\"\n },\n \"source_task_executions\": \"<unknown>\",\n \"started_at\": \"2023-11-07T05:31:56Z\",\n \"usage\": {\n \"task_executor_name\": \"doc_to_structured\",\n \"usage_metadata\": {}\n }\n}")
.asString();require 'uri'
require 'net/http'
url = URI("https://flows.super.ai/api/task-executions")
http = Net::HTTP.new(url.host, url.port)
http.use_ssl = true
request = Net::HTTP::Post.new(url)
request["Authorization"] = 'Bearer <token>'
request["Content-Type"] = 'application/json'
request.body = "{\n \"flow_execution_id\": \"123e4567-e89b-12d3-a456-426614174000\",\n \"processing_status\": \"running\",\n \"task_execution_idx\": 0,\n \"task_name\": \"send_email\",\n \"completed_at\": \"2023-11-07T05:31:56Z\",\n \"error\": {\n \"message\": \"Connection timeout after 30s\",\n \"traceback\": \"...\",\n \"type\": \"ConnectionError\"\n },\n \"input\": {\n \"recipient\": \"user@example.com\",\n \"subject\": \"Hello\"\n },\n \"output\": {\n \"email_id\": \"msg_123\",\n \"sent_at\": \"2025-01-23T10:30:00Z\"\n },\n \"source_task_executions\": \"<unknown>\",\n \"started_at\": \"2023-11-07T05:31:56Z\",\n \"usage\": {\n \"task_executor_name\": \"doc_to_structured\",\n \"usage_metadata\": {}\n }\n}"
response = http.request(request)
puts response.read_body{
"edited_status": "not_edited",
"flow_execution_id": "223e4567-e89b-12d3-a456-426614174000",
"id": "123e4567-e89b-12d3-a456-426614174000",
"organization_id": "323e4567-e89b-12d3-a456-426614174000",
"processing_status": "queued",
"stale_status": "consistent",
"task_execution_idx": 0,
"task_name": "send_email",
"completed_at": "2023-11-07T05:31:56Z",
"created_at": "2025-01-23T10:30:00Z",
"credits": 10,
"error": {
"message": "Connection timeout after 30 seconds",
"traceback": "Traceback (most recent call last):\n ...",
"type": "ConnectionError"
},
"input": {
"recipient": "user@example.com",
"subject": "Hello"
},
"modified_by": "system",
"output": {
"email_id": "msg_123",
"sent_at": "2025-01-23T10:30:00Z"
},
"source_task_executions": "<unknown>",
"started_at": "2023-11-07T05:31:56Z",
"updated_at": "2025-01-23T10:35:00Z",
"usage_recorded": true
}Authorizations
JWT Bearer token authentication. Include your access token in the Authorization header as: Bearer YOUR_ACCESS_TOKEN
Example:
Authorization: Bearer eyJhbGciOiJIUzI1NiIsInR5cCI6IkpXVCJ9...
Query Parameters
Controls delivery of large task values stored as GCS references. 'inline' (default) resolves references server-side and returns real values, subject to a per-request size budget (HTTP 413 when exceeded; individual references whose objects no longer exist are replaced by a 'gcs_ref_error' marker). 'refs' returns stored reference envelopes ('gcs_ref') untouched, to be resolved by the client.
inline, refs Body
Request model for creating or updating a task execution.
This model is used by system workers to report task execution state. Fields are intentionally simplified to reduce worker complexity. The server infers additional fields like organization_id and timestamps.
ID of the parent flow execution containing this task. Used to determine organization_id and maintain execution hierarchy.
"123e4567-e89b-12d3-a456-426614174000"
Processing lifecycle status of the task. Valid values: 'queued', 'running', 'completed', 'failed', 'cancelled'. Server validates against ProcessingStatus enum.
"running"
"completed"
"failed"
Zero-based execution index for this task. Increments for each execution of the same task (retries, loops). Combines with flow_execution_id and task_name to form unique identifier.
x >= 00
1
2
Name of the task as defined in the flow definition YAML. Must match a task name in the flow's task list. Case-sensitive identifier used for task lookups.
1 - 200"send_email"
"process_data"
"validate_input"
ISO 8601 UTC timestamp when task execution finished on the Temporal worker. Captures actual compute end time, unaffected by result posting delays.
Error information when task execution fails. Only set when status is 'failed'. Contains error message, type, and stack trace. Structure: {'message': str, 'type': str, 'traceback': str} Used for debugging and error reporting.
{
"message": "Connection timeout after 30s",
"traceback": "...",
"type": "ConnectionError"
}
Input parameters provided to the task executor. Schema varies by task type. Can be dict, list, or primitive types. NULL if task has no input parameters.
{
"recipient": "user@example.com",
"subject": "Hello"
}
[1, 2, 3, 4, 5]
"simple string input"
Output data produced by the task executor upon completion. Only set when status is 'completed'. NULL for queued/running/failed states. Available to downstream tasks via {{task_name.output}} syntax.
{
"email_id": "msg_123",
"sent_at": "2025-01-23T10:30:00Z"
}
{ "errors": 0, "processed_rows": 150 }
Tracks the original producer of this task's output data. Set by pass-through tasks (HITL, Branch, Validation) to propagate provenance. Structure: {'root': {'task_name': str, 'task_execution_idx': int}, 'fields': {...}}
ISO 8601 UTC timestamp when task execution started on the Temporal worker. Captures actual compute start time, unaffected by scheduling delays.
When set, the task-level status row is written in the same request (atomically with this execution row), so the task can never read as completed/failed before its result data exists. Set by the workflow engine on a task's final (carrier) result post only.
completed, failed When set, the task's usage (credits) is recorded in the same request and transaction as this execution row, replacing the separate usage post. Accepted from the system worker only. The response marks it with usage_recorded=true so an older API that ignores this field is detectable.
Show child attributes
Show child attributes
Response
Task execution created successfully
API model representing a task execution within a flow.
Task executions track individual task invocations during flow execution. Each task can execute multiple times (retries, loops), identified by task_execution_idx. Contains full execution context including inputs, outputs, errors, and lifecycle metadata.
Resource Hierarchy: Organization → Flow → Flow Execution → Task Execution
Whether this task execution was manually edited.
not_edited, edited_not_reexecuted, edited_reexecuted "not_edited"
"edited_not_reexecuted"
"edited_reexecuted"
ID of the parent flow execution containing this task. Establishes the execution hierarchy and determines organization scope. All tasks in a flow execution share the same flow_execution_id.
"223e4567-e89b-12d3-a456-426614174000"
Unique identifier for this task execution. Auto-generated UUID assigned at creation time. Used for direct resource access via GET /task-executions/{id}.
"123e4567-e89b-12d3-a456-426614174000"
ID of the organization owning this task execution. Inherited from parent flow execution for tenant isolation. Used for Row-Level Security (RLS) filtering and authorization. All task executions are scoped to a single organization.
"323e4567-e89b-12d3-a456-426614174000"
Processing lifecycle status of the task.
queued, running, completed, failed, deleted, awaiting_input, cancel_requested, cancelled, skipped "queued"
"running"
"completed"
"failed"
Whether this task execution's data is outdated.
consistent, stale "consistent"
"stale"
Zero-based execution index tracking task attempts. 0 = first execution, 1 = first retry, 2 = second retry, etc. Increments for each retry or loop iteration of the same task. Combines with flow_execution_id and task_name to form unique composite key.
x >= 00
1
2
Name of the task as defined in the flow definition YAML. Case-sensitive identifier matching flow configuration. Used to reference task in flow logic and dependency graphs.
1 - 200"send_email"
"process_data"
"validate_input"
ISO 8601 UTC timestamp when task execution finished on the Temporal worker. Captures actual compute end time, distinct from updated_at (API write time). NULL for legacy records or in-progress executions.
ISO 8601 timestamp when task execution was created (UTC). Represents when the task was queued or first recorded in the system. NULL for legacy records created before timestamp tracking.
"2025-01-23T10:30:00Z"
Total credits consumed by this task execution. None when no usage records exist for this task.
10
Error information when task execution fails. Only populated when status is 'failed'; NULL for other states. Contains error message, exception type, and stack trace for debugging.
Typical structure: { "message": "Human-readable error description", "type": "Exception class name", "traceback": "Full Python stack trace" }
Used for debugging, monitoring, and error reporting workflows.
{
"message": "Connection timeout after 30 seconds",
"traceback": "Traceback (most recent call last):\n ...",
"type": "ConnectionError"
}
Input parameters provided to the task executor. Schema varies by task type; can be object, array, or primitive. NULL if task accepts no input parameters. Resolved from flow definition and upstream task outputs.
{
"recipient": "user@example.com",
"subject": "Hello"
}
[1, 2, 3, 4, 5]
"simple string input"
Identifier of the actor who last modified this task execution. Tracks manual interventions vs automated updates for auditing. Defaults to 'system' for worker-initiated changes.
Values:
- 'system': System-automated changes (workers, background jobs)
- User ID: UUID string of the user who made the change (e.g., '123e4567-e89b-12d3-a456-426614174000')
- Integration type: For service accounts/integrations (e.g., 'integration', 'service-account')
"system"
"123e4567-e89b-12d3-a456-426614174000"
"integration"
Output data produced by the task executor upon successful completion. Only populated when status is 'completed'; NULL for other states. Available to downstream tasks via {{task_name.output}} syntax. Structure defined by task executor implementation. Used for task chaining and flow data propagation.
{
"email_id": "msg_123",
"sent_at": "2025-01-23T10:30:00Z"
}
Tracks the original producer of this task's output data. Set by pass-through tasks (HITL, Branch, Validation) to propagate provenance.
ISO 8601 UTC timestamp when task execution started on the Temporal worker. Captures actual compute start time, distinct from created_at (API write time). NULL for legacy records created before timing was tracked.
ISO 8601 timestamp of last update to this task execution (UTC). Changes whenever status, output, or error fields are modified. Used for change tracking and optimistic locking. NULL for records never updated since creation.
"2025-01-23T10:35:00Z"
Set to true only on the response of POST /task-executions when the request's inline usage was recorded in the same transaction. Null everywhere else.