1.16.16

flytekit.core.reference_entity

Directory

Classes

Class Description
LaunchPlanReference A reference object containing metadata that points to a remote launch plan.
Reference
ReferenceEntity
ReferenceSpec
ReferenceTemplate
TaskReference A reference object containing metadata that points to a remote task.
WorkflowReference A reference object containing metadata that points to a remote workflow.

flytekit.core.reference_entity.LaunchPlanReference

A reference object containing metadata that points to a remote launch plan.

Parameters 

class LaunchPlanReference(
    project: str,
    domain: str,
    name: str,
    version: str,
)
Parameter Type Description
project str
domain str
name str
version str

Properties

Property Type Description
id None
resource_type None

flytekit.core.reference_entity.Reference

Parameters 

class Reference(
    project: str,
    domain: str,
    name: str,
    version: str,
)
Parameter Type Description
project str
domain str
name str
version str

Properties

Property Type Description
id None
resource_type None

flytekit.core.reference_entity.ReferenceEntity

Parameters 

class ReferenceEntity(
    reference: typing.Union[flytekit.core.reference_entity.WorkflowReference, flytekit.core.reference_entity.TaskReference, flytekit.core.reference_entity.LaunchPlanReference],
    inputs: typing.Dict[str, typing.Type],
    outputs: typing.Dict[str, typing.Type],
)
Parameter Type Description
reference typing.Union[flytekit.core.reference_entity.WorkflowReference, flytekit.core.reference_entity.TaskReference, flytekit.core.reference_entity.LaunchPlanReference]
inputs typing.Dict[str, typing.Type]
outputs typing.Dict[str, typing.Type]

Properties

Property Type Description
id None
interface None
name None
python_interface None
reference None

Methods

Method Description
compile()
construct_node_metadata()
execute()
local_execute() Please see the local_execute comments in the main task.
local_execution_mode()
unwrap_literal_map_and_execute() Please see the implementation of the dispatch_execute function in the real task.

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()

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]

Please see the local_execute comments in the main task.

Parameter Type Description
ctx flytekit.core.context_manager.FlyteContext
kwargs **kwargs

local_execution_mode() 

def local_execution_mode()

unwrap_literal_map_and_execute() 

def unwrap_literal_map_and_execute(
    ctx: flytekit.core.context_manager.FlyteContext,
    input_literal_map: flytekit.models.literals.LiteralMap,
) -> flytekit.models.literals.LiteralMap

Please see the implementation of the dispatch_execute function in the real task.

Parameter Type Description
ctx flytekit.core.context_manager.FlyteContext
input_literal_map flytekit.models.literals.LiteralMap

flytekit.core.reference_entity.ReferenceSpec

Parameters 

class ReferenceSpec(
    template: flytekit.core.reference_entity.ReferenceTemplate,
)
Parameter Type Description
template flytekit.core.reference_entity.ReferenceTemplate

Properties

Property Type Description
template None

flytekit.core.reference_entity.ReferenceTemplate

Parameters 

class ReferenceTemplate(
    id: flytekit.models.core.identifier.Identifier,
    resource_type: int,
)

A reference template encapsulates all the information necessary to use reference entities within other workflows or dynamic tasks.

Parameter Type Description
id flytekit.models.core.identifier.Identifier
resource_type int

Properties

Property Type Description
id None User-specified information that uniquely identifies this reference.
resource_type None The type of reference.

flytekit.core.reference_entity.TaskReference

A reference object containing metadata that points to a remote task.

Parameters 

class TaskReference(
    project: str,
    domain: str,
    name: str,
    version: str,
)
Parameter Type Description
project str
domain str
name str
version str

Properties

Property Type Description
id None
resource_type None

flytekit.core.reference_entity.WorkflowReference

A reference object containing metadata that points to a remote workflow.

Parameters 

class WorkflowReference(
    project: str,
    domain: str,
    name: str,
    version: str,
)
Parameter Type Description
project str
domain str
name str
version str

Properties

Property Type Description
id None
resource_type None