Struct TaskExecutionContext 

pub struct TaskExecutionContext { /* private fields */ }

Task execution context passed to product task implementations.

Implementations

impl TaskExecutionContext

pub fn new( lease: TaskLease, renewal_timeout: Duration, shutdown_token: CancellationToken, ) -> Self

Creates a task execution context.

pub const fn lease_guard(&self) -> &TaskLeaseGuard

Returns the lease guard used by progress and heartbeat updates.

pub fn ensure_active(&self) -> Result<()>

Returns success only while the worker should continue task execution.

Errors

Returns TaskCoreError when the lease has been lost or shutdown was requested.

pub async fn sleep_or_shutdown(&self, duration: Duration) -> Result<()>

Sleeps until duration elapses or shutdown is requested.

Errors

Returns TaskCoreError when shutdown wins before the requested sleep completes.

pub async fn shutdown_requested(&self) -> Result<()>

Waits for shutdown and then returns the shutdown-requested lease error.

Errors

Returns TaskCoreError when shutdown or lease loss has been observed.

Trait Implementations

impl Clone for TaskExecutionContext

fn clone(&self) -> TaskExecutionContext

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for TaskExecutionContext

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

Formats the value using the given formatter.