From fa5aecbc7df99982336916172bebd93cda294de6 Mon Sep 17 00:00:00 2001 From: Matthias Beyer Date: Fri, 9 Apr 2021 11:48:20 +0200 Subject: Add --limit option to "db jobs" Signed-off-by: Matthias Beyer --- src/commands/db.rs | 12 +++++++++++- 1 file changed, 11 insertions(+), 1 deletion(-) (limited to 'src/commands/db.rs') diff --git a/src/commands/db.rs b/src/commands/db.rs index 7dbf08a..ba66c14 100644 --- a/src/commands/db.rs +++ b/src/commands/db.rs @@ -11,6 +11,7 @@ use std::io::Write; use std::path::PathBuf; use std::process::Command; +use std::str::FromStr; use anyhow::Context; use anyhow::Error; @@ -342,8 +343,17 @@ fn jobs(conn_cfg: DbConnectionConfig, matches: &ArgMatches) -> Result<()> { sel }; - let data = sel.load::<(models::Job, models::Submit, models::Endpoint, models::Package)>(&conn)? + let sel = if let Some(limit) = matches.value_of("limit").map(i64::from_str).transpose()? { + sel.limit(limit) + } else { + sel + }; + + let data = sel + .order_by(schema::jobs::id.desc()) // required for the --limit implementation + .load::<(models::Job, models::Submit, models::Endpoint, models::Package)>(&conn)? .into_iter() + .rev() // required for the --limit implementation .map(|(job, submit, ep, package)| { let success = crate::log::ParsedLog::build_from(&job.log_text)? .is_successfull() -- cgit v1.2.3