node_execution.proto

flyteidl.admin.NodeExecutionGetRequest

[flyteidl.admin.NodeExecutionGetRequest proto]

A message used to fetch a single node execution entity.

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

(flyteidl.core.NodeExecutionIdentifier) Uniquely identifies an individual node execution.

flyteidl.admin.NodeExecutionListRequest

[flyteidl.admin.NodeExecutionListRequest proto]

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

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

(flyteidl.core.WorkflowExecutionIdentifier) Indicates the workflow 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. +optional

flyteidl.admin.NodeExecutionForTaskListRequest

[flyteidl.admin.NodeExecutionForTaskListRequest proto]

Represents a request structure to retrieve a list of node execution entities launched by a specific task.

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

(flyteidl.core.TaskExecutionIdentifier) 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. +optional

flyteidl.admin.NodeExecution

[flyteidl.admin.NodeExecution proto]

Encapsulates all details for a single node execution entity. A node represents a component in the overall workflow graph. A node launch a task, multiple tasks, an entire nested sub-workflow, or even a separate child-workflow execution. The same task can be called repeatedly in a single workflow but each node is unique.

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

(flyteidl.core.NodeExecutionIdentifier) Uniquely identifies an individual node execution.

input_uri

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

closure

(flyteidl.admin.NodeExecutionClosure) Computed results associated with this node execution.

metadata

(flyteidl.admin.NodeExecutionMetaData) Metadata for Node Execution

flyteidl.admin.NodeExecutionMetaData

[flyteidl.admin.NodeExecutionMetaData proto]

Represents additional attributes related to a Node Execution

{}

flyteidl.admin.NodeExecutionList

[flyteidl.admin.NodeExecutionList proto]

Request structure to retrieve a list of node execution entities.

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

(flyteidl.admin.NodeExecution)

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.NodeExecutionClosure

[flyteidl.admin.NodeExecutionClosure proto]

Container for node execution details and results.

{
  "output_uri": "...",
  "error": "{...}",
  "phase": "...",
  "started_at": "{...}",
  "duration": "{...}",
  "created_at": "{...}",
  "updated_at": "{...}",
  "workflow_node_metadata": "{...}"
}
output_uri

(string) Only a node in a terminal state will have a non-empty output_result.

Only one of output_uri, error may be set.

error

(flyteidl.core.ExecutionError) Error information for the Node

Only a node in a terminal state will have a non-empty output_result.

Only one of output_uri, error may be set.

phase

(flyteidl.core.NodeExecution.Phase) The last recorded phase for this node execution.

started_at

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

duration

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

created_at

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

updated_at

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

workflow_node_metadata

(flyteidl.admin.WorkflowNodeMetadata) Store metadata for what the node launched. for ex: if this is a workflow node, we store information for the launched workflow.

flyteidl.admin.WorkflowNodeMetadata

[flyteidl.admin.WorkflowNodeMetadata proto]

Metadata for a WorkflowNode

{
  "executionId": "{...}"
}
executionId

(flyteidl.core.WorkflowExecutionIdentifier)

flyteidl.admin.NodeExecutionGetDataRequest

[flyteidl.admin.NodeExecutionGetDataRequest proto]

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

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

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

flyteidl.admin.NodeExecutionGetDataResponse

[flyteidl.admin.NodeExecutionGetDataResponse proto]

Response structure for NodeExecutionGetDataRequest which contains inputs and outputs for a node execution.

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

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

outputs

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