flytekit.remote.entities.FlyteLaunchPlan#

class flytekit.remote.entities.FlyteLaunchPlan(id, *args, **kwargs)[source]#

A class encapsulating a remote Flyte launch plan.

Methods

compile(ctx, *args, **kwargs)[source]#

Parameters: ctx (flytekit.core.context_manager.FlyteContext) –

construct_node_metadata()#

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

Return type: flytekit.models.core.workflow.NodeMetadata

execute(**kwargs)#

Return type: Any

classmethod from_flyte_idl(pb2)#

Parameters: pb2 (flyteidl.admin.launch_plan_pb2.LaunchPlanSpec) –
Return type: LaunchPlanSpec

local_execute(ctx, **kwargs)#

Parameters: ctx (flytekit.core.context_manager.FlyteContext) –
Return type: Optional[Union[Tuple[flytekit.core.promise.Promise], flytekit.core.promise.Promise, flytekit.core.promise.VoidPromise]]

classmethod promote_from_model(id, model)[source]#

Parameters

id (flytekit.models.core.identifier.Identifier) –
model (flytekit.models.launch_plan.LaunchPlanSpec) –

Return type

flytekit.remote.entities.FlyteLaunchPlan

serialize_to_string()#

Return type: str

short_string()#

Return type: Text

to_flyte_idl()#

Return type: flyteidl.admin.launch_plan_pb2.LaunchPlanSpec

verbose_string()#

Return type: Text

Attributes

annotations#: The annotations to execute the workflow with :rtype: flytekit.models.common.Annotations

auth_role#: The authorization method with which to execute the workflow. :rtype: flytekit.models.common.AuthRole

default_inputs#: Input values to be passed for the execution :rtype: flytekit.models.interface.ParameterMap

entity_metadata#

LaunchPlanMetadata

Type: rtype

entity_type_text#

fixed_inputs#: Fixed, non-overridable inputs for the Launch Plan :rtype: flytekit.models.literals.LiteralMap

flyte_workflow#

id#

interface#: The interface is not technically part of the admin.LaunchPlanSpec in the IDL, however the workflow ID is, and from the workflow ID, fetch will fill in the interface. This is nice because then you can __call__ the= object and get a node.

is_empty#

is_scheduled#

labels#: The labels to execute the workflow with :rtype: flytekit.models.common.Labels

max_parallelism#

name#

python_interface#

raw_output_data_config#: Where to store offloaded data like Blobs and Schemas :rtype: flytekit.models.common.RawOutputDataConfig

resource_type#

security_context#

workflow_id#