diff --git a/packages/queue/src/runner.rs b/packages/queue/src/runner.rs index ccbfac8..aea4711 100644 --- a/packages/queue/src/runner.rs +++ b/packages/queue/src/runner.rs @@ -121,8 +121,7 @@ async fn handle_job(queue: Arc, job: Job, db: &Pool) -> Res video_id: video_id.clone(), }, PostgresJobStatus::Queued, - // Some(scheduled_time), // TODO: Uncomment after testing - None, + Some(scheduled_time), // TODO: Uncomment after testing ) .await?;