diff --git a/Cargo.lock b/Cargo.lock index edf5c84..de7a335 100644 --- a/Cargo.lock +++ b/Cargo.lock @@ -3392,7 +3392,7 @@ dependencies = [ [[package]] name = "twba-uploader" -version = "0.1.0" +version = "0.2.0" dependencies = [ "anyhow", "chrono", diff --git a/Cargo.toml b/Cargo.toml index 5c4652b..ce4927a 100644 --- a/Cargo.toml +++ b/Cargo.toml @@ -1,6 +1,6 @@ [package] name = "twba-uploader" -version = "0.1.0" +version = "0.2.0" edition = "2021" # See more keys and their definitions at https://doc.rust-lang.org/cargo/reference/manifest.html diff --git a/src/client.rs b/src/client.rs index 1111fbc..444991c 100644 --- a/src/client.rs +++ b/src/client.rs @@ -12,7 +12,7 @@ use twba_local_db::entities::video_upload::{ActiveModel as VideoUploadActiveMode use twba_local_db::prelude::*; use twba_local_db::re_exports::sea_orm::{ ActiveModelTrait, ActiveValue, ColumnTrait, DatabaseConnection, EntityTrait, IntoActiveModel, - Order, QueryFilter, QueryOrder, + Order, QueryFilter, QueryOrder, QuerySelect, }; mod youtube; @@ -34,6 +34,7 @@ impl UploaderClient { let videos = Videos::find() .filter(VideosColumn::Status.eq(Status::Split)) .order_by(VideosColumn::CreatedAt, Order::Asc) + .limit(CONF.max_items_to_process) .all(&self.db) .await?; let count = videos.len();