flytekit.models.launch_plan
class 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 |
Description |
assumable_iam_role |
|
|
kubernetes_service_account |
|
|
| Property |
Type |
Description |
assumable_iam_role |
None |
The IAM role to execute the workflow with |
is_empty |
None |
|
kubernetes_service_account |
None |
The kubernetes service account to execute the workflow with |
def from_flyte_idl(
pb2_object,
)
| Parameter |
Type |
Description |
pb2_object |
|
|
Returns: Auth
def serialize_to_string()
Returns: Text
Returns: flyteidl.admin.launch_plan_pb2.Auth
class LaunchPlan(
id,
spec,
closure,
auto_activate,
)
| Parameter |
Type |
Description |
id |
|
|
spec |
|
|
closure |
|
|
auto_activate |
|
|
| Property |
Type |
Description |
closure |
None |
|
id |
None |
|
is_empty |
None |
|
should_auto_activate |
bool |
|
spec |
None |
|
def from_flyte_idl(
pb2_object,
)
| Parameter |
Type |
Description |
pb2_object |
|
|
Returns: LaunchPlan
def serialize_to_string()
Returns: Text
Returns: flyteidl.admin.launch_plan_pb2.LaunchPlan
class LaunchPlanClosure(
state,
expected_inputs,
expected_outputs,
)
| Parameter |
Type |
Description |
state |
|
|
expected_inputs |
|
|
expected_outputs |
|
|
| Property |
Type |
Description |
expected_inputs |
None |
|
expected_outputs |
None |
|
is_empty |
None |
|
state |
None |
|
def from_flyte_idl(
pb2_object,
)
| Parameter |
Type |
Description |
pb2_object |
|
|
Returns: LaunchPlanClosure
def serialize_to_string()
Returns: Text
Returns: flyteidl.admin.launch_plan_pb2.LaunchPlanClosure
class LaunchPlanMetadata(
schedule,
notifications,
launch_conditions,
)
| Parameter |
Type |
Description |
schedule |
|
|
notifications |
|
|
launch_conditions |
|
Additional metadata for launching |
| Property |
Type |
Description |
is_empty |
None |
|
launch_conditions |
None |
|
notifications |
None |
List of notifications based on Execution status transitions |
schedule |
None |
Schedule to execute the Launch Plan |
def from_flyte_idl(
pb2_object,
)
| Parameter |
Type |
Description |
pb2_object |
|
|
Returns: LaunchPlanMetadata
def serialize_to_string()
Returns: Text
List of notifications based on Execution status transitions
Returns: flyteidl.admin.launch_plan_pb2.LaunchPlanMetadata
class 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],
concurrency_policy: typing.Optional[flytekit.models.concurrency.ConcurrencyPolicy],
)
The spec for a Launch Plan.
| Parameter |
Type |
Description |
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] |
This can be used to add security information to a LaunchPlan, which will be used by every execution |
overwrite_cache |
typing.Optional[bool] |
|
concurrency_policy |
typing.Optional[flytekit.models.concurrency.ConcurrencyPolicy] |
|
| Property |
Type |
Description |
annotations |
flytekit.models.common.Annotations |
The annotations to execute the workflow with |
auth_role |
None |
The authorization method with which to execute the workflow. |
concurrency_policy |
typing.Optional[flytekit.models.concurrency.ConcurrencyPolicy] |
Concurrency settings for the launch plan. |
default_inputs |
None |
Input values to be passed for the execution |
entity_metadata |
None |
|
fixed_inputs |
None |
Fixed, non-overridable inputs for the Launch Plan |
is_empty |
None |
|
labels |
flytekit.models.common.Labels |
The labels to execute the workflow with |
max_parallelism |
typing.Optional[int] |
|
overwrite_cache |
typing.Optional[bool] |
|
raw_output_data_config |
None |
Where to store offloaded data like Blobs and Schemas |
security_context |
typing.Optional[flytekit.models.security.SecurityContext] |
|
workflow_id |
None |
Unique identifier for the workflow in question |
def from_flyte_idl(
pb2,
)
| Parameter |
Type |
Description |
pb2 |
|
|
Returns: LaunchPlanSpec
def serialize_to_string()
Returns: Text
Returns: flyteidl.admin.launch_plan_pb2.LaunchPlanSpec
def enum_to_string(
val,
)
| Parameter |
Type |
Description |
val |
|
|
Returns: Text