Skip to content

Commit

Permalink
fix some typos
Browse files Browse the repository at this point in the history
  • Loading branch information
maxcountryman committed Nov 17, 2024
1 parent bf627cd commit ab36387
Show file tree
Hide file tree
Showing 4 changed files with 9 additions and 9 deletions.
8 changes: 4 additions & 4 deletions src/job.rs
Original file line number Diff line number Diff line change
Expand Up @@ -251,7 +251,7 @@
//! # Atomicity
//!
//! Apart from state, context also provides another useful field: a transaction
//! that's shared wtih the worker.
//! that's shared with the worker.
//!
//! Access to this transaction means we can make updates to the database that
//! are only visible if the execution itself succeeds and the transaction is
Expand Down Expand Up @@ -293,7 +293,7 @@
//! # Retry policies
//!
//! Steps being tasks also have associated retry policies. This policy inherits
//! the default but can be providied for each step.
//! the default but can be provided for each step.
//!
//! ```rust
//! use serde::{Deserialize, Serialize};
Expand Down Expand Up @@ -487,7 +487,7 @@
//! # }
//! ```
//!
//! # Runnning jobs
//! # Running jobs
//!
//! Jobs are run via workers and schedulers, where the former processes tasks
//! and the latter processes schedules for enqueuing tasks. Starting both is
Expand Down Expand Up @@ -1415,7 +1415,7 @@ where
worker.run().await
}

/// Contructs a worker which then immediately runs schedule processing.
/// Constructs a worker which then immediately runs schedule processing.
///
/// # Errors
///
Expand Down
4 changes: 2 additions & 2 deletions src/queue.rs
Original file line number Diff line number Diff line change
Expand Up @@ -363,7 +363,7 @@ impl<T: Task> Queue<T> {
/// to the task and returned upon successful enqueue.
///
/// **Note:** If you pass a transactional executor and the transaction is
/// rolled back, the returned tasl ID will not correspond to any persisted
/// rolled back, the returned task ID will not correspond to any persisted
/// task.
///
/// # Errors
Expand Down Expand Up @@ -569,7 +569,7 @@ impl<T: Task> Queue<T> {
/// Dequeues the next available task.
///
/// This method uses the `FOR UPDATE SKIP LOCKED` clause to ensure efficient
/// retrievial of pending task rows.
/// retrieval of pending task rows.
///
/// If an available task is found, it's marked as "in progress".
///
Expand Down
2 changes: 1 addition & 1 deletion src/task.rs
Original file line number Diff line number Diff line change
Expand Up @@ -575,7 +575,7 @@ pub enum State {
/// Execute cancelled.
Cancelled,

/// Execute completed unsucessfully.
/// Execute completed unsuccessfully.
Failed,
}

Expand Down
4 changes: 2 additions & 2 deletions src/worker.rs
Original file line number Diff line number Diff line change
Expand Up @@ -10,7 +10,7 @@
//!
//! Also note that workers retry failed tasks in accordance with their
//! configured retry policies. When a task has remaining retries, it will be
//! requeued in a "pending" state.
//! re-enqueued in a "pending" state.
//!
//! To ensure that only a single worker can process a task at a time, a
//! [transaction-level advisory lock][advisory-locks] is held over either the
Expand Down Expand Up @@ -648,7 +648,7 @@ impl<T: Task + Sync> Worker<T> {
/// Processes the next available task in the queue.
///
/// When a task is found, its execute method will be invoked with the
/// deqeued input.
/// dequeued input.
///
/// If the execution exceeds the task's timeout then the execute future is
/// cancelled. This can also result in the task being marked failed if its
Expand Down

0 comments on commit ab36387

Please sign in to comment.