0.1.dev2192+g7c539c3.d20250403

flytekit.remote.lazy_entity

Directory

Classes

Class Description
LazyEntity Fetches the entity when the entity is called or when the entity is retrieved.

Variables

Property Type Description
T TypeVar

flytekit.remote.lazy_entity.LazyEntity

Fetches the entity when the entity is called or when the entity is retrieved. The entity is derived from RemoteEntity so that it behaves exactly like the mimicked entity.

class LazyEntity(
    name: str,
    getter: typing.Callable[[], ~T],
    args,
    kwargs,
)
Parameter Type
name str
getter typing.Callable[[], ~T]
args *args
kwargs **kwargs

Methods

Method Description
compile()
construct_node_metadata() Used when constructing the node that encapsulates this task as part of a broader workflow definition.
entity_fetched()
execute()
local_execute()
local_execution_mode()

compile() 

def compile(
    ctx: flytekit.core.context_manager.FlyteContext,
    args,
    kwargs,
)
Parameter Type
ctx flytekit.core.context_manager.FlyteContext
args *args
kwargs **kwargs

construct_node_metadata() 

def construct_node_metadata()

Used when constructing the node that encapsulates this task as part of a broader workflow definition.

entity_fetched() 

def entity_fetched()

execute() 

def execute(
    kwargs,
) -> typing.Any
Parameter Type
kwargs **kwargs

local_execute() 

def local_execute(
    ctx: flytekit.core.context_manager.FlyteContext,
    kwargs,
) -> typing.Union[typing.Tuple[flytekit.core.promise.Promise], flytekit.core.promise.Promise, flytekit.core.promise.VoidPromise, NoneType]
Parameter Type
ctx flytekit.core.context_manager.FlyteContext
kwargs **kwargs

local_execution_mode() 

def local_execution_mode()

Properties

Property Type Description
entity
If not already fetched / available, then the entity will be force fetched.
id
name
python_interface