1.16.16

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.

Parameters 

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

Properties

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

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 Description
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 Description
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 Description
ctx flytekit.core.context_manager.FlyteContext
kwargs **kwargs

local_execution_mode() 

def local_execution_mode()