Struct BatchJob 

pub struct BatchJob<D>
where
    D: Clone + Send + Sync + Serialize,
{
    pub id: String,
    pub resource_key: String,
    pub operation: String,
    pub overwrite_policy: OverwritePolicy,
    pub items: Vec<BatchItem<D>>,
    pub status: BatchJobStatus,
    pub created_at: String,
    pub started_at: Option<String>,
    pub completed_at: Option<String>,
    pub reordered: bool,
    pub reorder_note: Option<String>,
}

A batch job containing multiple items processed with the same resource.

The “resource key” (e.g. model name) is used for intelligent reordering: jobs sharing a resource are grouped together to minimize expensive resource swaps (GPU model loads, connection setup, etc.).

Fields

id: String

Unique job identifier.

resource_key: String

The resource key (e.g. model name) used for grouping.

operation: String

Human-readable operation label (e.g. “tag”, “caption”, “embed”).

overwrite_policy: OverwritePolicy

Overwrite policy for items that already have results.

items: Vec<BatchItem<D>>

The items in this batch.

status: BatchJobStatus

Current job status.

created_at: String

ISO 8601 timestamp when the job was created.

started_at: Option<String>

ISO 8601 timestamp when processing started.

completed_at: Option<String>

ISO 8601 timestamp when processing finished.

reordered: bool

Whether the job was reordered for resource optimization.

reorder_note: Option<String>

Human-readable note explaining the reorder.

Trait Implementations

impl<D> Clone for BatchJob<D>

where D: Clone + Send + Sync + Serialize + Clone,

fn clone(&self) -> BatchJob<D>

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<D> Debug for BatchJob<D>

where D: Clone + Send + Sync + Serialize + Debug,

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

Formats the value using the given formatter.

impl<'de, D> Deserialize<'de> for BatchJob<D>

where D: Clone + Send + Sync + Serialize + Deserialize<'de>,

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl<D> Serialize for BatchJob<D>

where D: Clone + Send + Sync + Serialize + Serialize,

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

where __S: Serializer,

Serialize this value into the given Serde serializer.