flytekit.models.concurrency

Class	Description
`ConcurrencyLimitBehavior`
`ConcurrencyPolicy`	Defines the concurrency policy for a launch plan.

flytekit.models.concurrency.ConcurrencyLimitBehavior

Method	Description
`enum_to_string()`

        
    
def enum_to_string(
    val,
)

Parameter	Type	Description
`val`

Defines the concurrency policy for a launch plan.

        
    
class ConcurrencyPolicy(
    max_concurrency: int,
    behavior: flytekit.models.concurrency.ConcurrencyLimitBehavior,
)

Parameter	Type	Description
`max_concurrency`	`int`
`behavior`	`flytekit.models.concurrency.ConcurrencyLimitBehavior`

        
    
def from_flyte_idl(
    pb2_object: flyteidl.admin.launch_plan_pb2.ConcurrencyPolicy,
) -> ConcurrencyPolicy

Parameter	Type	Description
`pb2_object`	`flyteidl.admin.launch_plan_pb2.ConcurrencyPolicy`

def serialize_to_string()

def short_string()

:rtype: Text

def to_flyte_idl()

:rtype: flyteidl.admin.launch_plan_pb2.ConcurrencyPolicy

Property	Type	Description
`behavior`		Policy behavior when concurrency limit is reached.
`is_empty`
`max_concurrency`		Maximum number of concurrent workflows allowed.