Struct TaskConfig 

#[non_exhaustive]
pub struct TaskConfig {

    pub max_retries: u32,
    pub retry_for_errors: Vec<String>,
    pub concurrency_control: ConcurrencyControlType,
    pub running_concurrency: Option<u32>,
    pub registration_concurrency: ConcurrencyControlType,
    pub cache_results: bool,
    pub key_arguments: Vec<String>,
    pub disable_cache_args: Vec<String>,
    pub on_diff_non_key_args_raise: bool,
    pub parallel_batch_size: usize,
    pub force_new_workflow: bool,
    pub reroute_on_cc: bool,
    pub blocking: bool,
}

Per-task configuration options.

Mirrors pynenc’s ConfigTask with settings for retries, concurrency, and execution behavior.

Fields (Non-exhaustive)

Non-exhaustive structs could have additional fields added in future. Therefore, non-exhaustive structs cannot be constructed in external crates using the traditional Struct { .. } syntax; cannot be matched against without a wildcard ..; and struct update syntax will not work.

max_retries: u32

Maximum number of retry attempts (0 = no retries)

retry_for_errors: Vec<String>

Error type names that should trigger a retry. Empty means only explicit RetryError triggers retries.

concurrency_control: ConcurrencyControlType

Concurrency control strategy for running invocations

running_concurrency: Option<u32>

Maximum number of concurrent invocations (when using Task concurrency)

registration_concurrency: ConcurrencyControlType

Concurrency control strategy applied at registration time

cache_results: bool

Whether to cache results for identical arguments

key_arguments: Vec<String>

Parameter names used as concurrency keys (when using Task concurrency)

disable_cache_args: Vec<String>

Argument names to exclude from cache key computation

on_diff_non_key_args_raise: bool

Raise an error when a call with matching key args but different non-key args is registered (prevents silent overwrites)

parallel_batch_size: usize

Batch size for parallelize() — how many calls to submit at once

force_new_workflow: bool

Force a new workflow even if a matching invocation already exists

reroute_on_cc: bool

Reroute an invocation when it hits concurrency control limits

blocking: bool

Whether to run this task on a blocking thread (tokio::task::spawn_blocking). Use for CPU-bound or synchronous I/O tasks that could starve the async executor.

Trait Implementations

impl Clone for TaskConfig

fn clone(&self) -> TaskConfig

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for TaskConfig

fn fmt(&self, f: &mut Formatter<'_>) -> Result<(), Error>

Formats the value using the given formatter.

impl Default for TaskConfig

fn default() -> TaskConfig

Returns the “default value” for a type.

impl<'de> Deserialize<'de> for TaskConfig

fn deserialize<__D>( __deserializer: __D, ) -> Result<TaskConfig, <__D as Deserializer<'de>>::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for TaskConfig

fn serialize<__S>( &self, __serializer: __S, ) -> Result<<__S as Serializer>::Ok, <__S as Serializer>::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.