NewTaskExecutionContext

NewTaskExecutionContext creates a TaskExecutionContext from a TaskAction and supporting dependencies.

def NewTaskExecutionContext(
    taskAction: *flyteorgv1.TaskAction,
    dataStore: *storage.DataStore,
    pluginStateMgr: *PluginStateManager,
    secretManager: pluginsCore.SecretManager,
    resourceManager: pluginsCore.ResourceManager,
    catalogClient: catalog.AsyncClient
) - > (*taskExecutionContext, error)

Creates a TaskExecutionContext from a TaskAction and supporting dependencies. This function initializes all necessary components like task readers, input/output handlers, and metadata for task execution.

Parameters

Name	Type	Description
taskAction	*flyteorgv1.TaskAction	The TaskAction object containing the task specification and current status.
dataStore	*storage.DataStore	The data store client used for reading and writing task inputs and outputs.
pluginStateMgr	*PluginStateManager	The plugin state manager for handling plugin-specific state.
secretManager	pluginsCore.SecretManager	The secret manager for accessing sensitive information required by the task.
resourceManager	pluginsCore.ResourceManager	The resource manager for handling task-related resources.
catalogClient	catalog.AsyncClient	The catalog client for interacting with the catalog service.

Returns

Type	Description
(*taskExecutionContext, error)	A new TaskExecutionContext instance or an error if initialization fails.