Struct JobContext 

pub struct JobContext {
    pub job: JobRow,
    /* private fields */
}

Context passed to worker handlers during job execution.

Provides access to the job metadata, shared state (e.g., service dependencies), callback registration, and structured progress reporting.

Fields

job: JobRow

The raw job row from the database.

Implementations

impl JobContext

pub fn new( job: JobRow, cancelled: Arc<AtomicBool>, state: Arc<HashMap<TypeId, Box<dyn Any + Send + Sync>>>, pool: PgPool, progress: Arc<Mutex<ProgressState>>, ) -> Self

pub fn is_cancelled(&self) -> bool

Check if this job’s execution has been cancelled (shutdown or deadline).

pub fn cancellation_flag(&self) -> Arc<AtomicBool>

Clone the shared cancellation flag for language bridges.

pub fn cancel(&self)

Signal cancellation for this job.

pub fn extract<T: Any + Send + Sync + Clone>(&self) -> Option<T>

Extract a shared state value by type.

State values are registered via Client::builder().state(value).

pub fn pool(&self) -> &PgPool

Get a reference to the database pool.

pub async fn register_callback( &self, timeout: Duration, ) -> Result<CallbackToken, AwaError>

Register a callback for this job, writing the callback_id to the database immediately.

Call this BEFORE sending the callback_id to the external system to avoid the race condition where the external system fires before the DB knows about the callback.

Returns a CallbackToken whose id should be included in the URL or payload sent to the external system.

pub async fn register_callback_with_config( &self, timeout: Duration, config: &CallbackConfig, ) -> Result<CallbackToken, AwaError>

Register a callback with CEL expressions for automatic resolution.

See CallbackConfig for expression semantics.

pub fn set_progress(&self, percent: u8, message: Option<&str>)

Set structured progress (0-100, optional message). Sync — writes to in-memory buffer.

percent is clamped to 0-100.

pub fn update_metadata(&self, updates: Value) -> Result<(), AwaError>

Shallow-merge keys into progress.metadata for checkpointing. Sync.

updates must be a JSON object. Top-level keys overwrite; nested objects are replaced, not deep-merged.

pub async fn flush_progress(&self) -> Result<(), AwaError>

Force immediate flush of pending progress to DB. For critical checkpoints.

Does not return success until the progress has been durably written or the job is no longer in running state (rescued/cancelled).

pub fn progress_buffer(&self) -> Arc<Mutex<ProgressState>>

Get a clone of the shared progress state Arc (for Python bridge).