Struct ExceptionPolicy 

pub struct ExceptionPolicy {
    pub retry_on: Vec<String>,
    pub ignore_on: Vec<String>,
    pub fail_on: Vec<String>,
    pub reject_on: Vec<String>,
    pub default_action: ExceptionAction,
    pub preserve_traceback: bool,
    pub max_traceback_depth: Option<usize>,
    pub include_metadata: HashMap<String, bool>,
}

Policy for handling exceptions

Fields

retry_on: Vec<String>

Exception types to retry on (by type name pattern)

ignore_on: Vec<String>

Exception types to ignore (task succeeds despite exception)

fail_on: Vec<String>

Exception types to fail on (no retry, go to DLQ)

reject_on: Vec<String>

Exception types to reject (no retry, no DLQ)

default_action: ExceptionAction

Default action for unmatched exceptions

preserve_traceback: bool

Whether to preserve full traceback

max_traceback_depth: Option<usize>

Maximum traceback depth to preserve

include_metadata: HashMap<String, bool>

Custom metadata to include in exceptions

Implementations

impl ExceptionPolicy

pub fn new() -> Self

Create a new exception policy with defaults

pub fn retry_on(self, types: &[&str]) -> Self

Set exception types to retry on

pub fn add_retry_on(self, exc_type: impl Into<String>) -> Self

Add exception type to retry on

pub fn ignore_on(self, types: &[&str]) -> Self

Set exception types to ignore

pub fn add_ignore_on(self, exc_type: impl Into<String>) -> Self

Add exception type to ignore

pub fn fail_on(self, types: &[&str]) -> Self

Set exception types to fail on

pub fn add_fail_on(self, exc_type: impl Into<String>) -> Self

Add exception type to fail on

pub fn reject_on(self, types: &[&str]) -> Self

Set exception types to reject

pub fn add_reject_on(self, exc_type: impl Into<String>) -> Self

Add exception type to reject

pub fn with_default_action(self, action: ExceptionAction) -> Self

Set default action

pub fn with_traceback(self, preserve: bool) -> Self

Set traceback preservation

pub fn with_max_traceback_depth(self, depth: usize) -> Self

Set maximum traceback depth

pub fn get_action(&self, exception: &TaskException) -> ExceptionAction

Get the action to take for an exception

pub fn process_exception(&self, exception: TaskException) -> TaskException

Process an exception according to policy

Trait Implementations

impl Clone for ExceptionPolicy

fn clone(&self) -> ExceptionPolicy

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for ExceptionPolicy

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

Formats the value using the given formatter.

impl Default for ExceptionPolicy

fn default() -> Self

Returns the “default value” for a type.

impl<'de> Deserialize<'de> for ExceptionPolicy

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for ExceptionPolicy

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

where __S: Serializer,

Serialize this value into the given Serde serializer.