Struct GpuJob 

pub struct GpuJob {
    pub id: String,
    pub model: String,
    pub request: GenerateRequest,
    pub progress_tx: Option<UnboundedSender<SseMessage>>,
    pub result_tx: Sender<Result<GenerationJobResult, String>>,
    pub output_dir: Option<PathBuf>,
    pub config: Arc<RwLock<Config>>,
    pub metadata_db: Arc<Option<MetadataDb>>,
    pub queue: QueueHandle,
    pub registry: SharedJobRegistry,
    pub events: Arc<EventBroadcaster>,
}

A job dispatched to a GPU worker thread for processing.

Fields

id: String

Server-assigned UUIDv4 carried over from GenerationJob.id. Used by the worker to flip the registry entry from Queued → Running (and to remove it when the job finishes), and surfaced to clients via GET /api/queue for zombie-card reconciliation.

model: String

request: GenerateRequest

progress_tx: Option<UnboundedSender<SseMessage>>

result_tx: Sender<Result<GenerationJobResult, String>>

output_dir: Option<PathBuf>

config: Arc<RwLock<Config>>

metadata_db: Arc<Option<MetadataDb>>

Metadata DB handle so the worker can record a row alongside the on-disk save. Arc<Option<...>> mirrors AppState.metadata_db — None when the DB failed to open or is disabled.

queue: QueueHandle

Decrement the global queue counter when the worker finishes this job.

registry: SharedJobRegistry

Job registry handle so the worker can flip state to Running on pickup and remove the entry on completion / error. Cheap clone — registry is behind an Arc<RwLock> internally.

events: Arc<EventBroadcaster>

Server-wide event broadcast so the worker’s save path can emit gallery_added alongside the DB upsert (mirrors AppState.events).