Struct TaskQuery 

pub struct TaskQuery {
    pub status: Option<String>,
    pub kind: Option<String>,
    pub parent_id: Option<Uuid>,
    pub root_only: bool,
    pub name: Option<String>,
    pub queue_name: Option<String>,
    pub sort: TaskSort,
    pub limit: Option<u64>,
    pub offset: Option<u64>,
}

Builder for filtering, sorting, and paginating task queries.

let query = TaskQuery::default()
    .status("RUNNING")
    .kind("WORKFLOW")
    .root_only(true)
    .sort(TaskSort::CreatedAt(Order::Desc))
    .limit(20);
let tasks = Ctx::list(&db, query).await?;

Fields

status: Option<String>

kind: Option<String>

parent_id: Option<Uuid>

root_only: bool

name: Option<String>

queue_name: Option<String>

sort: TaskSort

limit: Option<u64>

offset: Option<u64>

Implementations

impl TaskQuery

pub fn status(self, status: &str) -> Self

Filter by status (e.g. “RUNNING”, “PAUSED”, “CANCELLED”, “COMPLETED”, “FAILED”, “PENDING”).

pub fn kind(self, kind: &str) -> Self

Filter by kind (e.g. “WORKFLOW”, “STEP”, “TRANSACTION”).

pub fn parent_id(self, parent_id: Uuid) -> Self

Filter by parent task ID (direct children only).

pub fn root_only(self, root_only: bool) -> Self

Only return root tasks (no parent).

pub fn name(self, name: &str) -> Self

Filter by task name.

pub fn queue_name(self, queue: &str) -> Self

Filter by queue name.

pub fn sort(self, sort: TaskSort) -> Self

Set the sort order.

pub fn limit(self, limit: u64) -> Self

Limit the number of results.

pub fn offset(self, offset: u64) -> Self

Skip the first N results.

Trait Implementations

impl Default for TaskQuery

fn default() -> Self

Returns the “default value” for a type.