Function initialize_queue_workers

Source
pub async fn initialize_queue_workers(
    app_state: ThinData<DefaultAppState>,
) -> Result<Vec<WorkerHandle>>
Expand description

Creates the queue backend and initializes all workers in a single step.

This consolidates queue backend creation (from QUEUE_BACKEND env var), worker initialization, and logging into a single bootstrap function, keeping main.rs free of queue implementation details.

§Arguments

  • app_state - Application state containing the job producer and configuration

§Returns

Vector of worker handles for all spawned workers