Skip to main content

NewNodeExecutionK8sReader

Initializes and returns a new NodeExecutionK8sReader instance. This function sets up the reader with necessary metadata such as namespace, execution ID, node ID, and a Kubernetes client cache, preparing it to read Kubernetes resources related to a specific node execution.

def NewNodeExecutionK8sReader(
meta: pluginsCore.TaskExecutionMetadata,
client: pluginsCore.KubeClient
) - > *NodeExecutionK8sReader

Creates and returns a new NodeExecutionK8sReader instance, initialized with metadata about a task execution and a Kubernetes client. This reader is used to access Kubernetes resources related to a specific node execution.

Parameters

NameTypeDescription
metapluginsCore.TaskExecutionMetadataMetadata containing information about the task execution, including the task execution ID, which is used to derive the execution ID, node ID, and namespace.
clientpluginsCore.KubeClientA Kubernetes client used to interact with the Kubernetes API, specifically its cached version, for retrieving node execution-related resources.

Returns

TypeDescription
*NodeExecutionK8sReaderA new NodeExecutionK8sReader instance configured for the specified node execution.