From 08063feef207f3086f394b3829b4965f98d5672e Mon Sep 17 00:00:00 2001
From: Christoph Kluge <christoph.kluge@fau.de>
Date: Thu, 29 Jun 2023 14:59:51 +0200
Subject: [PATCH 1/6] Add listQuery link to job view concurrentJobs

---
 web/frontend/src/Job.root.svelte | 5 +++--
 1 file changed, 3 insertions(+), 2 deletions(-)

diff --git a/web/frontend/src/Job.root.svelte b/web/frontend/src/Job.root.svelte
index 438a277..3d8e58e 100644
--- a/web/frontend/src/Job.root.svelte
+++ b/web/frontend/src/Job.root.svelte
@@ -27,7 +27,7 @@
             resources { hostname, hwthreads, accelerators },
             metaData,
             userData { name, email },
-            concurrentJobs { items { id, jobId }, count }
+            concurrentJobs { items { id, jobId }, count, listQuery }
         }
     `)
 
@@ -118,11 +118,12 @@
         {/if}
     </Col>
     {#if $jobMetrics.data && $initq.data}
-        {#if $initq.data.job.concurrentJobs != null}
+        {#if $initq.data.job.concurrentJobs.items.length != 0}
             {#if authlevel > roles.manager}
                 <Col>
                     <h5>Concurrent Jobs <Icon name="info-circle" style="cursor:help;" title="Shared jobs running on the same node with overlapping runtimes"/></h5>
                     <ul>
+                        <li><a href="/monitoring/jobs/?{$initq.data.job.concurrentJobs.listQuery}" target="_blank">See All</a></li>
                     {#each $initq.data.job.concurrentJobs.items as pjob, index}
                         <li><a href="/monitoring/job/{pjob.id}" target="_blank">{pjob.jobId}</a></li>
                     {/each}

From b5a7249ad5a67f3931c03a42b8ba91c0460f9a31 Mon Sep 17 00:00:00 2001
From: Jan Eitzinger <jan@moebiusband.org>
Date: Fri, 30 Jun 2023 09:15:58 +0200
Subject: [PATCH 2/6] Fix sqlite migration for configuration

---
 .../migrations/sqlite3/06_change-config.down.sql   | 14 ++++++++++----
 .../migrations/sqlite3/06_change-config.up.sql     | 14 ++++++++++----
 2 files changed, 20 insertions(+), 8 deletions(-)

diff --git a/internal/repository/migrations/sqlite3/06_change-config.down.sql b/internal/repository/migrations/sqlite3/06_change-config.down.sql
index 74a8299..eccc0ce 100644
--- a/internal/repository/migrations/sqlite3/06_change-config.down.sql
+++ b/internal/repository/migrations/sqlite3/06_change-config.down.sql
@@ -1,4 +1,10 @@
-ALTER TABLE configuration ADD COLUMN value_new varchar(255);
-INSERT INTO configuration (value_new) SELECT value FROM configuration;
-ALTER TABLE configuration DROP COLUMN  value;
-ALTER TABLE configuration RENAME COLUMN value_new TO value;
+CREATE TABLE IF NOT EXISTS configuration_new (
+username varchar(255),
+confkey  varchar(255),
+value    varchar(255),
+PRIMARY KEY (username, confkey),
+FOREIGN KEY (username) REFERENCES user (username) ON DELETE CASCADE ON UPDATE NO ACTION);
+
+INSERT INTO configuration_new SELECT * FROM configuration;
+DROP TABLE configuration;
+ALTER TABLE configuration_new RENAME TO configuration;
diff --git a/internal/repository/migrations/sqlite3/06_change-config.up.sql b/internal/repository/migrations/sqlite3/06_change-config.up.sql
index 0dae70c..408ce21 100644
--- a/internal/repository/migrations/sqlite3/06_change-config.up.sql
+++ b/internal/repository/migrations/sqlite3/06_change-config.up.sql
@@ -1,4 +1,10 @@
-ALTER TABLE configuration ADD COLUMN value_new TEXT;
-INSERT INTO configuration (value_new) SELECT value FROM configuration;
-ALTER TABLE configuration DROP COLUMN  value;
-ALTER TABLE configuration RENAME COLUMN value_new TO value;
+CREATE TABLE IF NOT EXISTS configuration_new (
+username varchar(255),
+confkey  varchar(255),
+value    text,
+PRIMARY KEY (username, confkey),
+FOREIGN KEY (username) REFERENCES user (username) ON DELETE CASCADE ON UPDATE NO ACTION);
+
+INSERT INTO configuration_new SELECT * FROM configuration;
+DROP TABLE configuration;
+ALTER TABLE configuration_new RENAME TO configuration;

From c04aea89c93035e9b50c8058769dcb05031eeebc Mon Sep 17 00:00:00 2001
From: Christoph Kluge <christoph.kluge@fau.de>
Date: Fri, 30 Jun 2023 12:01:27 +0200
Subject: [PATCH 3/6] Implement node filter in frontend, fix backend

- Add running job count and link to list to single node view
---
 internal/routerConfig/routes.go           |  3 +
 web/frontend/src/Node.root.svelte         | 72 +++++++++++++++++++----
 web/frontend/src/filters/Filters.svelte   | 12 ++++
 web/frontend/src/filters/Resources.svelte | 14 +++--
 4 files changed, 85 insertions(+), 16 deletions(-)

diff --git a/internal/routerConfig/routes.go b/internal/routerConfig/routes.go
index 3c38a02..c6b777c 100644
--- a/internal/routerConfig/routes.go
+++ b/internal/routerConfig/routes.go
@@ -184,6 +184,9 @@ func buildFilterPresets(query url.Values) map[string]interface{} {
 			}
 		}
 	}
+	if query.Get("node") != "" {
+		filterPresets["node"] = query.Get("node")
+	}
 	if query.Get("numNodes") != "" {
 		parts := strings.Split(query.Get("numNodes"), "-")
 		if len(parts) == 2 {
diff --git a/web/frontend/src/Node.root.svelte b/web/frontend/src/Node.root.svelte
index ef4a00c..40c3ce3 100644
--- a/web/frontend/src/Node.root.svelte
+++ b/web/frontend/src/Node.root.svelte
@@ -23,7 +23,7 @@
     const ccconfig = getContext('cc-config')
     const clusters = getContext('clusters')
     const client = getContextClient();
-    const query = gql`query($cluster: String!, $nodes: [String!], $from: Time!, $to: Time!) {
+    const nodeMetricsQuery = gql`query($cluster: String!, $nodes: [String!], $from: Time!, $to: Time!) {
         nodeMetrics(cluster: $cluster, nodes: $nodes, from: $from, to: $to) {
             host
             subCluster
@@ -42,9 +42,9 @@
         }
     }`;
 
-    $: nodesQuery = queryStore({
+    $: nodeMetricsData = queryStore({
         client: client,
-        query: query,
+        query: nodeMetricsQuery,
         variables: {
             cluster: cluster,
             nodes: [hostname],
@@ -53,8 +53,44 @@
         }
     });
 
+    let itemsPerPage = ccconfig.plot_list_jobsPerPage;
+    let page = 1;
+    let paging = { itemsPerPage, page };
+    let sorting = { field: "startTime", order: "DESC" };
+    $: filter = [
+        {cluster: { eq: cluster }},
+        {node: { eq: hostname }},
+        {state: 'running'},
+        {startTime: { 
+            from: from.toISOString(),
+            to: to.toISOString() 
+        }}    
+    ];
+
+    const nodeJobsQuery = gql`
+        query (
+            $filter: [JobFilter!]!
+            $sorting: OrderByInput!
+            $paging: PageRequest!
+        ) {
+            jobs(filter: $filter, order: $sorting, page: $paging) {
+                # items {
+                #     id
+                #     jobId
+                # }
+                count
+            }
+        }
+    `;
+
+    $: nodeJobsData = queryStore({
+        client: client,
+        query: nodeJobsQuery,
+        variables: { paging, sorting, filter }
+    });
+
     let metricUnits = {}
-    $: if ($nodesQuery.data) {
+    $: if ($nodeMetricsData.data) {
         let thisCluster = clusters.find(c => c.name == cluster)
         if (thisCluster) {
             for (let metric of thisCluster.metricConfig) {
@@ -67,7 +103,7 @@
         }
     }
 
-    // $: console.log($nodesQuery?.data?.nodeMetrics[0].metrics)
+    const dateToUnixEpoch = rfc3339 => Math.floor(Date.parse(rfc3339) / 1000)
 </script>
 
 <Row>
@@ -82,6 +118,18 @@
                 <InputGroupText>{hostname} ({cluster})</InputGroupText>
             </InputGroup>
         </Col>
+        <Col>
+            {#if $nodeJobsData.fetching }
+                <Spinner/>
+            {:else}
+                {#if $nodeJobsData.data}
+                    Currently running jobs on this node: { $nodeJobsData.data.jobs.count }
+                    [ <a href="/monitoring/jobs/?cluster={cluster}&state=running&startTime={dateToUnixEpoch(from)}-{dateToUnixEpoch(to)}&node={hostname}" target="_blank">View in Job List</a> ]
+                {:else}
+                    No currently running jobs.
+                {/if}
+            {/if}
+        </Col>
         <Col>
             <TimeSelection
                 bind:from={from}
@@ -92,9 +140,9 @@
 <br/>
 <Row>
     <Col>
-        {#if $nodesQuery.error}
-            <Card body color="danger">{$nodesQuery.error.message}</Card>
-        {:else if $nodesQuery.fetching || $initq.fetching}
+        {#if $nodeMetricsData.error}
+            <Card body color="danger">{$nodeMetricsData.error.message}</Card>
+        {:else if $nodeMetricsData.fetching || $initq.fetching}
             <Spinner/>
         {:else}
             <PlotTable
@@ -102,18 +150,18 @@
                 let:width
                 renderFor="node"
                 itemsPerRow={ccconfig.plot_view_plotsPerRow}
-                items={$nodesQuery.data.nodeMetrics[0].metrics
-                .map(m => ({ ...m, disabled: checkMetricDisabled(m.name, cluster, $nodesQuery.data.nodeMetrics[0].subCluster)}))
+                items={$nodeMetricsData.data.nodeMetrics[0].metrics
+                .map(m => ({ ...m, disabled: checkMetricDisabled(m.name, cluster, $nodeMetricsData.data.nodeMetrics[0].subCluster)}))
                 .sort((a, b) => a.name.localeCompare(b.name))}>
 
                 <h4 style="text-align: center; padding-top:15px;">{item.name} {metricUnits[item.name]}</h4>
                 {#if item.disabled === false && item.metric}
                     <MetricPlot
                         width={width} height={300} metric={item.name} timestep={item.metric.timestep}
-                        cluster={clusters.find(c => c.name == cluster)} subCluster={$nodesQuery.data.nodeMetrics[0].subCluster}
+                        cluster={clusters.find(c => c.name == cluster)} subCluster={$nodeMetricsData.data.nodeMetrics[0].subCluster}
                         series={item.metric.series} />
                 {:else if item.disabled === true && item.metric}
-                    <Card style="margin-left: 2rem;margin-right: 2rem;" body color="info">Metric disabled for subcluster <code>{item.name}:{$nodesQuery.data.nodeMetrics[0].subCluster}</code></Card>
+                    <Card style="margin-left: 2rem;margin-right: 2rem;" body color="info">Metric disabled for subcluster <code>{item.name}:{$nodeMetricsData.data.nodeMetrics[0].subCluster}</code></Card>
                 {:else}
                     <Card style="margin-left: 2rem;margin-right: 2rem;" body color="warning">No dataset returned for <code>{item.name}</code></Card>
                 {/if}
diff --git a/web/frontend/src/filters/Filters.svelte b/web/frontend/src/filters/Filters.svelte
index 1431293..f05a4cd 100644
--- a/web/frontend/src/filters/Filters.svelte
+++ b/web/frontend/src/filters/Filters.svelte
@@ -47,6 +47,7 @@
         project:     filterPresets.project    || '',
         jobName:     filterPresets.jobName    || '',
 
+        node:             filterPresets.node             || null,
         numNodes:         filterPresets.numNodes         || { from: null, to: null },
         numHWThreads:     filterPresets.numHWThreads     || { from: null, to: null },
         numAccelerators:  filterPresets.numAccelerators  || { from: null, to: null },
@@ -74,6 +75,8 @@
         let items = []
         if (filters.cluster)
             items.push({ cluster: { eq: filters.cluster } })
+        if (filters.node)
+            items.push({ node: { contains: filters.node } })
         if (filters.partition)
             items.push({ partition: { eq: filters.partition } })
         if (filters.states.length != allJobStates.length)
@@ -114,6 +117,8 @@
         let opts = []
         if (filters.cluster)
             opts.push(`cluster=${filters.cluster}`)
+        if (filters.node)
+            opts.push(`node=${filters.node}`)
         if (filters.partition)
             opts.push(`partition=${filters.partition}`)
         if (filters.states.length != allJobStates.length)
@@ -272,6 +277,12 @@
             </Info>
         {/if}
 
+        {#if filters.node != null }
+           <Info icon="hdd-stack" on:click={() => (isResourcesOpen = true)}>
+               Node: {filters.node}
+           </Info>
+        {/if}
+
         {#if filters.stats.length > 0}
             <Info icon="bar-chart" on:click={() => (isStatsOpen = true)}>
                 {filters.stats.map(stat => `${stat.text}: ${stat.from} - ${stat.to}`).join(', ')}
@@ -318,6 +329,7 @@
     bind:numNodes={filters.numNodes}
     bind:numHWThreads={filters.numHWThreads}
     bind:numAccelerators={filters.numAccelerators}
+    bind:namedNode={filters.node}
     bind:isNodesModified={isNodesModified}
     bind:isHwthreadsModified={isHwthreadsModified}
     bind:isAccsModified={isAccsModified}
diff --git a/web/frontend/src/filters/Resources.svelte b/web/frontend/src/filters/Resources.svelte
index ae1bc10..be5995a 100644
--- a/web/frontend/src/filters/Resources.svelte
+++ b/web/frontend/src/filters/Resources.svelte
@@ -16,8 +16,9 @@
     export let isNodesModified = false
     export let isHwthreadsModified = false
     export let isAccsModified = false
+    export let namedNode = null
 
-    let pendingNumNodes = numNodes, pendingNumHWThreads = numHWThreads, pendingNumAccelerators = numAccelerators
+    let pendingNumNodes = numNodes, pendingNumHWThreads = numHWThreads, pendingNumAccelerators = numAccelerators, pendingNamedNode = namedNode
 
     const findMaxNumAccels = clusters => clusters.reduce((max, cluster) => Math.max(max,
         cluster.subClusters.reduce((max, sc) => Math.max(max, sc.topology.accelerators?.length || 0), 0)), 0)
@@ -76,7 +77,9 @@
         Select number of utilized Resources
     </ModalHeader>
     <ModalBody>
-        <h6>Number of Nodes</h6>
+        <h6>Named Node</h6>
+            <input type="text" class="form-control"  bind:value={pendingNamedNode}>
+        <h6 style="margin-top: 1rem;">Number of Nodes</h6>
         <DoubleRangeSlider
             on:change={({ detail }) => {
                 pendingNumNodes = { from: detail[0], to: detail[1] }
@@ -117,7 +120,8 @@
                 numNodes ={ from: pendingNumNodes.from, to: pendingNumNodes.to }
                 numHWThreads = { from: pendingNumHWThreads.from, to: pendingNumHWThreads.to }
                 numAccelerators = { from: pendingNumAccelerators.from, to: pendingNumAccelerators.to }
-                dispatch('update', { numNodes, numHWThreads, numAccelerators })
+                namedNode = pendingNamedNode
+                dispatch('update', { numNodes, numHWThreads, numAccelerators, namedNode })
             }}>
             Close & Apply
         </Button>
@@ -126,13 +130,15 @@
             pendingNumNodes = { from: null, to: null }
             pendingNumHWThreads = { from: null, to: null }
             pendingNumAccelerators = { from: null, to: null }
+            pendingNamedNode = null
             numNodes = { from: pendingNumNodes.from, to: pendingNumNodes.to }
             numHWThreads = { from: pendingNumHWThreads.from, to: pendingNumHWThreads.to }
             numAccelerators = { from: pendingNumAccelerators.from, to: pendingNumAccelerators.to }
             isNodesModified = false
             isHwthreadsModified = false
             isAccsModified = false
-            dispatch('update', { numNodes, numHWThreads, numAccelerators })
+            namedNode = pendingNamedNode
+            dispatch('update', { numNodes, numHWThreads, numAccelerators, namedNode})
         }}>Reset</Button>
         <Button on:click={() => (isOpen = false)}>Close</Button>
     </ModalFooter>

From aacb7489e6b95bd40a0943df63ec655a2ea8594f Mon Sep 17 00:00:00 2001
From: Christoph Kluge <christoph.kluge@fau.de>
Date: Fri, 30 Jun 2023 15:04:01 +0200
Subject: [PATCH 4/6] StartTime not required for jobs running on node

---
 web/frontend/src/Node.root.svelte | 10 +++++-----
 1 file changed, 5 insertions(+), 5 deletions(-)

diff --git a/web/frontend/src/Node.root.svelte b/web/frontend/src/Node.root.svelte
index 40c3ce3..39c9eaf 100644
--- a/web/frontend/src/Node.root.svelte
+++ b/web/frontend/src/Node.root.svelte
@@ -60,11 +60,11 @@
     $: filter = [
         {cluster: { eq: cluster }},
         {node: { eq: hostname }},
-        {state: 'running'},
-        {startTime: { 
-            from: from.toISOString(),
-            to: to.toISOString() 
-        }}    
+        {state: 'running'}
+        // {startTime: { 
+        //     from: from.toISOString(),
+        //     to: to.toISOString() 
+        // }}    
     ];
 
     const nodeJobsQuery = gql`

From 4729905322246b28fa282ed7310dac58801cc3c4 Mon Sep 17 00:00:00 2001
From: Christoph Kluge <christoph.kluge@fau.de>
Date: Fri, 30 Jun 2023 15:06:26 +0200
Subject: [PATCH 5/6] Forgot to adapt link

---
 web/frontend/src/Node.root.svelte | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/web/frontend/src/Node.root.svelte b/web/frontend/src/Node.root.svelte
index 39c9eaf..f5715c9 100644
--- a/web/frontend/src/Node.root.svelte
+++ b/web/frontend/src/Node.root.svelte
@@ -124,7 +124,7 @@
             {:else}
                 {#if $nodeJobsData.data}
                     Currently running jobs on this node: { $nodeJobsData.data.jobs.count }
-                    [ <a href="/monitoring/jobs/?cluster={cluster}&state=running&startTime={dateToUnixEpoch(from)}-{dateToUnixEpoch(to)}&node={hostname}" target="_blank">View in Job List</a> ]
+                    [ <a href="/monitoring/jobs/?cluster={cluster}&state=running&node={hostname}" target="_blank">View in Job List</a> ]
                 {:else}
                     No currently running jobs.
                 {/if}

From 2f471dc19217ef3478c8060c17fc69e3652a33bb Mon Sep 17 00:00:00 2001
From: Christoph Kluge <christoph.kluge@fau.de>
Date: Fri, 30 Jun 2023 16:55:34 +0200
Subject: [PATCH 6/6] Change listQuery to jobId array, adapt filter pipe

---
 internal/repository/job.go              | 17 ++++-------------
 internal/repository/query.go            |  6 +++---
 internal/routerConfig/routes.go         |  8 +++++++-
 web/frontend/src/filters/Filters.svelte | 16 +++++++++++++---
 4 files changed, 27 insertions(+), 20 deletions(-)

diff --git a/internal/repository/job.go b/internal/repository/job.go
index 8f00124..b712a86 100644
--- a/internal/repository/job.go
+++ b/internal/repository/job.go
@@ -10,7 +10,6 @@ import (
 	"encoding/json"
 	"errors"
 	"fmt"
-	"math"
 	"strconv"
 	"sync"
 	"time"
@@ -18,7 +17,6 @@ import (
 	"github.com/ClusterCockpit/cc-backend/internal/auth"
 	"github.com/ClusterCockpit/cc-backend/internal/graph/model"
 	"github.com/ClusterCockpit/cc-backend/internal/metricdata"
-	"github.com/ClusterCockpit/cc-backend/internal/util"
 	"github.com/ClusterCockpit/cc-backend/pkg/log"
 	"github.com/ClusterCockpit/cc-backend/pkg/lrucache"
 	"github.com/ClusterCockpit/cc-backend/pkg/schema"
@@ -318,7 +316,7 @@ func (r *JobRepository) FindConcurrentJobs(
 		stopTime = startTime + int64(job.Duration)
 	}
 
-	// Add 5m overlap for jobs start time at the end
+	// Add 200s overlap for jobs start time at the end
 	startTimeTail := startTime + 10
 	stopTimeTail := stopTime - 200
 	startTimeFront := startTime + 200
@@ -338,8 +336,7 @@ func (r *JobRepository) FindConcurrentJobs(
 	}
 
 	items := make([]*model.JobLink, 0, 10)
-	minStart := int64(math.MaxInt64)
-	maxStart := int64(0)
+	queryString := fmt.Sprintf("cluster=%s", job.Cluster)
 
 	for rows.Next() {
 		var id, jobId, startTime sql.NullInt64
@@ -350,9 +347,7 @@ func (r *JobRepository) FindConcurrentJobs(
 		}
 
 		if id.Valid {
-			minStart = util.Min(minStart, startTime.Int64)
-			maxStart = util.Max(maxStart, startTime.Int64)
-
+			queryString += fmt.Sprintf("&jobId=%d", int(jobId.Int64))
 			items = append(items,
 				&model.JobLink{
 					ID:    fmt.Sprint(id.Int64),
@@ -376,9 +371,7 @@ func (r *JobRepository) FindConcurrentJobs(
 		}
 
 		if id.Valid {
-			minStart = util.Min(minStart, startTime.Int64)
-			maxStart = util.Max(maxStart, startTime.Int64)
-
+			queryString += fmt.Sprintf("&jobId=%d", int(jobId.Int64))
 			items = append(items,
 				&model.JobLink{
 					ID:    fmt.Sprint(id.Int64),
@@ -388,8 +381,6 @@ func (r *JobRepository) FindConcurrentJobs(
 	}
 
 	cnt := len(items)
-	queryString := fmt.Sprintf("cluster=%s&startTime=%d-%d&node=%s",
-		job.Cluster, minStart, maxStart, hostname)
 
 	return &model.JobLinkResultList{
 		ListQuery: &queryString,
diff --git a/internal/repository/query.go b/internal/repository/query.go
index d6a9c75..02e5304 100644
--- a/internal/repository/query.go
+++ b/internal/repository/query.go
@@ -263,11 +263,11 @@ func buildStringCondition(field string, cond *model.StringInput, query sq.Select
 		return query.Where(field+" LIKE ?", fmt.Sprint("%", *cond.Contains, "%"))
 	}
 	if cond.In != nil {
-		queryUsers := make([]string, len(cond.In))
+		queryElements := make([]string, len(cond.In))
 		for i, val := range cond.In {
-			queryUsers[i] = val
+			queryElements[i] = val
 		}
-		return query.Where(sq.Or{sq.Eq{"job.user": queryUsers}})
+		return query.Where(sq.Or{sq.Eq{field: queryElements}})
 	}
 	return query
 }
diff --git a/internal/routerConfig/routes.go b/internal/routerConfig/routes.go
index c6b777c..351941a 100644
--- a/internal/routerConfig/routes.go
+++ b/internal/routerConfig/routes.go
@@ -208,7 +208,13 @@ func buildFilterPresets(query url.Values) map[string]interface{} {
 		}
 	}
 	if query.Get("jobId") != "" {
-		filterPresets["jobId"] = query.Get("jobId")
+		if len(query["jobId"]) == 1 {
+			filterPresets["jobId"] = query.Get("jobId")
+			filterPresets["jobIdMatch"] = "eq"
+		} else {
+			filterPresets["jobId"] = query["jobId"]
+			filterPresets["jobIdMatch"] = "in"
+		}
 	}
 	if query.Get("arrayJobId") != "" {
 		if num, err := strconv.Atoi(query.Get("arrayJobId")); err == nil {
diff --git a/web/frontend/src/filters/Filters.svelte b/web/frontend/src/filters/Filters.svelte
index f05a4cd..38d7e7a 100644
--- a/web/frontend/src/filters/Filters.svelte
+++ b/web/frontend/src/filters/Filters.svelte
@@ -32,8 +32,9 @@
     export let startTimeQuickSelect = false
 
     let filters = {
-        projectMatch: filterPresets.projectMatch || 'contains',
-        userMatch:    filterPresets.userMatch    || 'contains',
+        projectMatch: filterPresets.projectMatch  || 'contains',
+        userMatch:    filterPresets.userMatch     || 'contains',
+        jobIdMatch:   filterPresets.jobIdMatch    || 'eq',
 
         cluster:     filterPresets.cluster    || null,
         partition:   filterPresets.partition  || null,
@@ -88,7 +89,7 @@
         if (filters.duration.from || filters.duration.to)
             items.push({ duration: { from: filters.duration.from, to: filters.duration.to } })
         if (filters.jobId)
-            items.push({ jobId: { eq: filters.jobId } })
+            items.push({ jobId: { [filters.jobIdMatch]: filters.jobId } })
         if (filters.arrayJobId != null)
             items.push({ arrayJobId: filters.arrayJobId })
         if (filters.numNodes.from != null || filters.numNodes.to != null)
@@ -130,6 +131,15 @@
             // } else {
                 opts.push(`startTime=${dateToUnixEpoch(filters.startTime.from)}-${dateToUnixEpoch(filters.startTime.to)}`)
             // }
+        if (filters.jobId.length != 0)
+            if (filters.jobIdMatch != 'in') {
+                opts.push(`jobId=${filters.jobId}`)
+            } else {
+                for (let singleJobId of filters.jobId)
+                opts.push(`jobId=${singleJobId}`)
+            }
+        if (filters.jobIdMatch != 'eq')
+            opts.push(`jobIdMatch=${filters.jobIdMatch}`)
         for (let tag of filters.tags)
             opts.push(`tag=${tag}`)
         if (filters.duration.from && filters.duration.to)