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#