flytekit.models.launch_plan
Directory
Classes
flytekit.models.launch_plan.Any
A ProtocolMessage
Methods
Method |
Description |
Is() |
Checks if this Any represents the given protobuf type |
Pack() |
Packs the specified message into current Any message |
TypeName() |
Returns the protobuf type name of the inner message |
Unpack() |
Unpacks the current Any message into specified message |
Is()
Checks if this Any represents the given protobuf type.
Parameter |
Type |
descriptor |
|
Pack()
def Pack(
msg,
type_url_prefix,
deterministic,
):
Packs the specified message into current Any message.
Parameter |
Type |
msg |
|
type_url_prefix |
|
deterministic |
|
TypeName()
Returns the protobuf type name of the inner message.
Unpack()
Unpacks the current Any message into specified message.
flytekit.models.launch_plan.Auth
def Auth(
assumable_iam_role,
kubernetes_service_account,
):
DEPRECATED. Do not use. Use flytekit.models.common.AuthRole instead
At most one of assumable_iam_role or kubernetes_service_account can be set.
Parameter |
Type |
assumable_iam_role |
|
kubernetes_service_account |
|
Methods
from_flyte_idl()
def from_flyte_idl(
pb2_object,
):
Parameter |
Type |
pb2_object |
|
serialize_to_string()
def serialize_to_string()
short_string()
to_flyte_idl()
verbose_string()
Properties
Property |
Type |
Description |
assumable_iam_role |
|
|
is_empty |
|
|
kubernetes_service_account |
|
|
flytekit.models.launch_plan.LaunchPlan
def LaunchPlan(
id,
spec,
closure,
auto_activate,
):
Parameter |
Type |
id |
|
spec |
|
closure |
|
auto_activate |
|
Methods
from_flyte_idl()
def from_flyte_idl(
pb2_object,
):
Parameter |
Type |
pb2_object |
|
serialize_to_string()
def serialize_to_string()
short_string()
to_flyte_idl()
verbose_string()
Properties
Property |
Type |
Description |
closure |
|
|
id |
|
|
is_empty |
|
|
should_auto_activate |
|
|
spec |
|
|
flytekit.models.launch_plan.LaunchPlanClosure
def LaunchPlanClosure(
state,
expected_inputs,
expected_outputs,
):
Parameter |
Type |
state |
|
expected_inputs |
|
expected_outputs |
|
Methods
from_flyte_idl()
def from_flyte_idl(
pb2_object,
):
Parameter |
Type |
pb2_object |
|
serialize_to_string()
def serialize_to_string()
short_string()
to_flyte_idl()
verbose_string()
Properties
Property |
Type |
Description |
expected_inputs |
|
|
expected_outputs |
|
|
is_empty |
|
|
state |
|
|
def LaunchPlanMetadata(
schedule,
notifications,
launch_conditions,
):
Parameter |
Type |
schedule |
|
notifications |
|
launch_conditions |
|
Methods
from_flyte_idl()
def from_flyte_idl(
pb2_object,
):
Parameter |
Type |
pb2_object |
|
serialize_to_string()
def serialize_to_string()
short_string()
to_flyte_idl()
List of notifications based on Execution status transitions
verbose_string()
Properties
Property |
Type |
Description |
is_empty |
|
|
launch_conditions |
|
|
notifications |
|
|
schedule |
|
|
flytekit.models.launch_plan.LaunchPlanSpec
def LaunchPlanSpec(
workflow_id,
entity_metadata,
default_inputs,
fixed_inputs,
labels: flytekit.models.common.Labels,
annotations: flytekit.models.common.Annotations,
auth_role: flytekit.models.common.AuthRole,
raw_output_data_config: flytekit.models.common.RawOutputDataConfig,
max_parallelism: typing.Optional[int],
security_context: typing.Optional[flytekit.models.security.SecurityContext],
overwrite_cache: typing.Optional[bool],
):
The spec for a Launch Plan.
Parameter |
Type |
workflow_id |
|
entity_metadata |
|
default_inputs |
|
fixed_inputs |
|
labels |
flytekit.models.common.Labels |
annotations |
flytekit.models.common.Annotations |
auth_role |
flytekit.models.common.AuthRole |
raw_output_data_config |
flytekit.models.common.RawOutputDataConfig |
max_parallelism |
typing.Optional[int] |
security_context |
typing.Optional[flytekit.models.security.SecurityContext] |
overwrite_cache |
typing.Optional[bool] |
Methods
from_flyte_idl()
def from_flyte_idl(
pb2,
):
serialize_to_string()
def serialize_to_string()
short_string()
to_flyte_idl()
verbose_string()
Properties
Property |
Type |
Description |
annotations |
|
|
auth_role |
|
|
default_inputs |
|
|
entity_metadata |
|
|
fixed_inputs |
|
|
is_empty |
|
|
labels |
|
|
max_parallelism |
|
|
overwrite_cache |
|
|
raw_output_data_config |
|
|
security_context |
|
|
workflow_id |
|
|
flytekit.models.launch_plan.LaunchPlanState
Methods
enum_to_string()
def enum_to_string(
val,
):