The page you navigated to () does not exist, so we brought you to the closest page to it.
You have switched from the to the variant of this site. There is no equivalent of . We have taken you to the closest page in the variant.
1.16.16
flytekit.models.concurrency
Directory
Classes
| Class | Description |
|---|---|
ConcurrencyLimitBehavior |
|
ConcurrencyPolicy |
Defines the concurrency policy for a launch plan. |
flytekit.models.concurrency.ConcurrencyLimitBehavior
Methods
| Method | Description |
|---|---|
enum_to_string() |
enum_to_string()
def enum_to_string(
val,
)| Parameter | Type | Description |
|---|---|---|
val |
Returns: Text
flytekit.models.concurrency.ConcurrencyPolicy
Defines the concurrency policy for a launch plan.
Parameters
class ConcurrencyPolicy(
max_concurrency: int,
behavior: flytekit.models.concurrency.ConcurrencyLimitBehavior,
)| Parameter | Type | Description |
|---|---|---|
max_concurrency |
int |
|
behavior |
flytekit.models.concurrency.ConcurrencyLimitBehavior |
Properties
| Property | Type | Description |
|---|---|---|
behavior |
None |
Policy behavior when concurrency limit is reached. |
is_empty |
None |
|
max_concurrency |
None |
Maximum number of concurrent workflows allowed. |
Methods
| Method | Description |
|---|---|
from_flyte_idl() |
|
serialize_to_string() |
|
short_string() |
|
to_flyte_idl() |
from_flyte_idl()
def from_flyte_idl(
pb2_object: flyteidl.admin.launch_plan_pb2.ConcurrencyPolicy,
) -> ConcurrencyPolicy| Parameter | Type | Description |
|---|---|---|
pb2_object |
flyteidl.admin.launch_plan_pb2.ConcurrencyPolicy |
Returns: ConcurrencyPolicy
serialize_to_string()
def serialize_to_string()short_string()
def short_string()Returns: Text
to_flyte_idl()
def to_flyte_idl()Returns: flyteidl.admin.launch_plan_pb2.ConcurrencyPolicy