summaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authorMatthias Beyer <matthias.beyer@atos.net>2021-06-07 14:26:46 +0200
committerMatthias Beyer <matthias.beyer@atos.net>2021-06-07 15:38:54 +0200
commit51b70e647230fb6df95dd3b0d35ce77409e73afb (patch)
tree33d458bce8c87e5adebf8fae64408a48468ecd27
parent037275412fb72a27c8bb0347d047e1a2b65e0569 (diff)
Add package filtering for "db jobs" subcommand
Signed-off-by: Matthias Beyer <matthias.beyer@atos.net>
-rw-r--r--src/cli.rs10
-rw-r--r--src/commands/db.rs4
2 files changed, 14 insertions, 0 deletions
diff --git a/src/cli.rs b/src/cli.rs
index 6da612e..cdf35d3 100644
--- a/src/cli.rs
+++ b/src/cli.rs
@@ -303,6 +303,16 @@ pub fn cli<'a>() -> App<'a> {
.about("Only show jobs from ENDPOINT")
)
+ .arg(Arg::new("package")
+ .required(false)
+ .multiple(false)
+ .long("package")
+ .short('p')
+ .takes_value(true)
+ .value_name("PKG")
+ .about("Only show jobs for PKG")
+ )
+
)
.subcommand(App::new("job")
diff --git a/src/commands/db.rs b/src/commands/db.rs
index a296579..08ed6c8 100644
--- a/src/commands/db.rs
+++ b/src/commands/db.rs
@@ -461,6 +461,10 @@ fn jobs(conn_cfg: DbConnectionConfig<'_>, matches: &ArgMatches) -> Result<()> {
sel = sel.filter(schema::endpoints::name.eq(ep_name))
}
+ if let Some(pkg_name) = matches.value_of("package") {
+ sel = sel.filter(schema::packages::name.eq(pkg_name))
+ }
+
let data = sel
.order_by(schema::jobs::id.desc()) // required for the --limit implementation
.load::<(models::Job, models::Submit, models::Endpoint, models::Package)>(&conn)?