task_execution.proto

flyteidl.admin.TaskExecutionGetRequest

[flyteidl.admin.TaskExecutionGetRequest proto]

A message used to fetch a single task execution entity.

{
  "id": "{...}"
}
id

(flyteidl.core.TaskExecutionIdentifier) Unique identifier for the task execution.

flyteidl.admin.TaskExecutionListRequest

[flyteidl.admin.TaskExecutionListRequest proto]

Represents a request structure to retrieve a list of task execution entities.

{
  "node_execution_id": "{...}",
  "limit": "...",
  "token": "...",
  "filters": "...",
  "sort_by": "{...}"
}
node_execution_id

(flyteidl.core.NodeExecutionIdentifier) Indicates the node execution to filter by.

limit

(uint32) Indicates the number of resources to be returned.

token

(string) In the case of multiple pages of results, the server-provided token can be used to fetch the next page in a query. +optional

filters

(string) Indicates a list of filters passed as string. More info on constructing filters : <Link> +optional

sort_by

(flyteidl.admin.Sort) Sort ordering for returned list. +optional

flyteidl.admin.TaskExecution

[flyteidl.admin.TaskExecution proto]

Encapsulates all details for a single task execution entity. A task execution represents an instantiated task, including all inputs and additional metadata as well as computed results included state, outputs, and duration-based attributes.

{
  "id": "{...}",
  "input_uri": "...",
  "closure": "{...}",
  "is_parent": "..."
}
id

(flyteidl.core.TaskExecutionIdentifier) Unique identifier for the task execution.

input_uri

(string) Path to remote data store where input blob is stored.

closure

(flyteidl.admin.TaskExecutionClosure) Task execution details and results.

is_parent

(bool) Whether this task spawned nodes.

flyteidl.admin.TaskExecutionList

[flyteidl.admin.TaskExecutionList proto]

Response structure for a query to list of task execution entities.

{
  "task_executions": [],
  "token": "..."
}
task_executions

(flyteidl.admin.TaskExecution)

token

(string) In the case of multiple pages of results, the server-provided token can be used to fetch the next page in a query. If there are no more results, this value will be empty.

flyteidl.admin.TaskExecutionClosure

[flyteidl.admin.TaskExecutionClosure proto]

Container for task execution details and results.

{
  "output_uri": "...",
  "error": "{...}",
  "phase": "...",
  "logs": [],
  "started_at": "{...}",
  "duration": "{...}",
  "created_at": "{...}",
  "updated_at": "{...}",
  "custom_info": "{...}"
}
output_uri

(string) Path to remote data store where output blob is stored if the execution succeeded (and produced outputs).

Only one of output_uri, error may be set.

error

(flyteidl.core.ExecutionError) Error information for the task execution. Populated if the execution failed.

Only one of output_uri, error may be set.

phase

(flyteidl.core.TaskExecution.Phase) The last recorded phase for this task execution.

logs

(flyteidl.core.TaskLog) Detailed log information output by the task execution.

started_at

(google.protobuf.Timestamp) Time at which the task execution began running.

duration

(google.protobuf.Duration) The amount of time the task execution spent running.

created_at

(google.protobuf.Timestamp) Time at which the task execution was created.

updated_at

(google.protobuf.Timestamp) Time at which the task execution was last updated.

custom_info

(google.protobuf.Struct) Custom data specific to the task plugin.

flyteidl.admin.TaskExecutionGetDataRequest

[flyteidl.admin.TaskExecutionGetDataRequest proto]

Request structure to fetch inputs and output urls for a task execution.

{
  "id": "{...}"
}
id

(flyteidl.core.TaskExecutionIdentifier) The identifier of the task execution for which to fetch inputs and outputs.

flyteidl.admin.TaskExecutionGetDataResponse

[flyteidl.admin.TaskExecutionGetDataResponse proto]

Response structure for TaskExecutionGetDataRequest which contains inputs and outputs for a task execution.

{
  "inputs": "{...}",
  "outputs": "{...}"
}
inputs

(flyteidl.admin.UrlBlob) Signed url to fetch a core.LiteralMap of task execution inputs.

outputs

(flyteidl.admin.UrlBlob) Signed url to fetch a core.LiteralMap of task execution outputs.