Struct Task 

pub struct Task {

    pub id: TaskUuid,
    pub name: String,
    pub operator_id: String,
    pub input_collection_id: CollectionUuid,
    pub output_collection_name: String,
    pub output_collection_id: Option<String>,
    pub params: Option<String>,
    pub tenant_id: String,
    pub database_id: String,
    pub last_run: Option<SystemTime>,
    pub next_run: Option<SystemTime>,
    pub completion_offset: u64,
    pub min_records_for_task: u64,
    pub is_deleted: bool,
    pub created_at: SystemTime,
    pub updated_at: SystemTime,
}

Task represents an asynchronous task that is triggered by collection writes to map records from a source collection to a target collection.

Fields

id: TaskUuid

Unique identifier for the task

name: String

Human-readable name for the task instance

operator_id: String

Name of the operator/built-in definition this task uses (despite field name, this is a name not a UUID)

input_collection_id: CollectionUuid

Source collection that triggers the task

output_collection_name: String

Name of target collection where task output is stored

output_collection_id: Option<String>

ID of the output collection (lazily filled in after creation)

params: Option<String>

Optional JSON parameters for the operator

tenant_id: String

Tenant name this task belongs to (despite field name, this is a name not a UUID)

database_id: String

Database name this task belongs to (despite field name, this is a name not a UUID)

last_run: Option<SystemTime>

Timestamp of the last successful task run

next_run: Option<SystemTime>

Timestamp when the task should next run (None if not yet scheduled)

completion_offset: u64

Completion offset: the WAL position up to which the task has processed records

min_records_for_task: u64

Minimum number of new records required before the task runs again

is_deleted: bool

Whether the task has been soft-deleted

created_at: SystemTime

Timestamp when the task was created

updated_at: SystemTime

Timestamp when the task was last updated

Trait Implementations

impl Clone for Task

fn clone(&self) -> Task

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for Task

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for Task

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for Task

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

where __S: Serializer,

Serialize this value into the given Serde serializer.