flytekit.remote.lazy_entity
| Class |
Description |
LazyEntity |
Fetches the entity when the entity is called or when the entity is retrieved. |
| Property |
Type |
Description |
T |
TypeVar |
|
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 |
Description |
name |
str |
|
getter |
typing.Callable[[], ~T] |
|
*args |
|
|
**kwargs |
|
|
| Property |
Type |
Description |
entity |
~T |
If not already fetched / available, then the entity will be force fetched. |
id |
flytekit.models.core.identifier.Identifier |
|
name |
str |
|
python_interface |
typing.Optional[ForwardRef('Interface')] |
|
def compile(
ctx: flytekit.core.context_manager.FlyteContext,
*args,
**kwargs,
)
| Parameter |
Type |
Description |
ctx |
flytekit.core.context_manager.FlyteContext |
|
*args |
|
|
**kwargs |
|
|
def construct_node_metadata()
Used when constructing the node that encapsulates this task as part of a broader workflow definition.
def execute(
**kwargs,
) -> typing.Any
| Parameter |
Type |
Description |
**kwargs |
|
|
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 |
|
|
def local_execution_mode()
