flyte.models

Directory

Classes

Class	Description
`ActionID`	A class representing the ID of an Action, nested within a Run.
`ActionPhase`	Represents the execution phase of a Flyte action (run).
`CallCounter`	Numbers identical sub-action calls made from one action scope: `foo(); foo(); foo()` → 1, 2, 3.
`CheckpointPaths`	Paths the platform provides for this task’s checkpoint output and optional previous-attempt input.
`CodeBundle`	A class representing a code bundle for a task.
`GroupData`
`NativeInterface`	A class representing the native interface for a task.
`PathRewrite`	Configuration for rewriting paths during input loading.
`RawDataPath`	A class representing the raw data path for a task.
`SerializationContext`	This object holds serialization time contextual information, that can be used when serializing the task and various parameters of a tasktemplate.
`TaskContext`	A context class to hold the current task executions context.

Methods

Method	Description
`generate_random_name()`	Generate a random name for the task.
`is_clustered_worker_env()`	True for any worker process of a clustered/jobset task, regardless of which launcher started it.

Variables

Property	Type	Description
`CLUSTERED_WORKER_ENV`	`str`
`MAX_GROUP_NAME_LENGTH`	`int`
`MAX_INLINE_IO_BYTES`	`int`
`NULL_TASK_CONTEXT`	`_NullTaskContext`
`TYPE_CHECKING`	`bool`

Methods

generate_random_name()

        
    
def generate_random_name()

Generate a random name for the task. This is used to create unique names for tasks. TODO we can use unique-namer in the future, for now its just guids

is_clustered_worker_env()

        
    
def is_clustered_worker_env(
    env: Mapping[str, str],
) -> bool

True for any worker process of a clustered/jobset task, regardless of which launcher started it.

Parameter	Type	Description
`env`	`Mapping[str, str]`