Job queue size

client/platform/web-girder/views/Jobs.vue

@@ -1,8 +1,11 @@
 <script lang="ts">
-import { defineComponent, ref } from '@vue/composition-api';
+import {
+  defineComponent, ref, toRef, watch,
+} from '@vue/composition-api';
 import { GirderJobList } from '@girder/components/src';
 import { setUsePrivateQueue } from 'platform/web-girder/api';
 import { useGirderRest } from 'platform/web-girder/plugins/girder';
+import { useStore } from '../store/types';
 
 export default defineComponent({
   name: 'Jobs',
@@ -11,6 +14,14 @@ export default defineComponent({
     const privateQueueEnabled = ref(false);
     const loading = ref(true);
     const restClient = useGirderRest();
+    const store = useStore();
+    const outstandingJobs = ref(0);
+
+    watch(toRef(store.getters, 'Jobs/runningJobIds'), () => {
+      restClient.get('job/queued').then(({ data }) => {
+        outstandingJobs.value = data.outstanding;
+      });
+    });
 
     async function setPrivateQueueEnabled(value: boolean) {
       loading.value = true;
@@ -24,10 +35,14 @@ export default defineComponent({
         privateQueueEnabled.value = user.user_private_queue_enabled;
         loading.value = false;
       });
+    restClient.get('job/queued').then(({ data }) => {
+      outstandingJobs.value = data.outstanding;
+    });
 
     return {
       privateQueueEnabled,
       loading,
+      outstandingJobs,
       /* methods */
       setPrivateQueueEnabled,
     };
@@ -37,6 +52,13 @@ export default defineComponent({
 
 <template>
   <v-container :fluid="$vuetify.breakpoint.mdAndDown">
+    <v-alert
+      v-if="outstandingJobs"
+      type="warning"
+    >
+      There are {{ outstandingJobs }} jobs currently in the job queue (including yours).
+      Jobs will be processed in the order in which they are received.
+    </v-alert>
     <GirderJobList>
       <template #jobwidget="{ item }">
         <v-tooltip

server/dive_server/__init__.py

@@ -17,7 +17,7 @@
 from .views_annotation import AnnotationResource
 from .views_configuration import ConfigurationResource
 from .views_dataset import DatasetResource
-from .views_override import use_private_queue
+from .views_override import countJobs, use_private_queue
 from .views_rpc import RpcResource
 
 
@@ -33,6 +33,7 @@ def load(self, info):
         info["apiRoot"].dive_rpc = RpcResource("dive_rpc")
 
         # Setup route additions for exsting resources
+        info['apiRoot'].job.route("GET", ("queued",), countJobs)
         info["apiRoot"].user.route("PUT", (":id", "use_private_queue"), use_private_queue)
         User().exposeFields(AccessType.READ, constants.UserPrivateQueueEnabledMarker)
 

server/dive_server/views_override.py

@@ -4,6 +4,8 @@
 from girder.api.rest import boundHandler
 from girder.constants import AccessType
 from girder.models.user import User
+from girder_jobs.models import job
+from girder_worker.utils import JobStatus
 
 from dive_utils import constants
 
@@ -30,3 +32,31 @@ def use_private_queue(self, user: dict, privateQueueEnabled: bool):
             constants.UserPrivateQueueEnabledMarker, False
         ),
     }
+
+
+@access.user
+@boundHandler
+@autoDescribeRoute(Description('Get number of outstanding jobs'))
+def countJobs(self):
+    outstanding = (
+        job.Job()
+        .list(
+            user='all',
+            currentUser=self.getCurrentUser(),
+            statuses=[
+                JobStatus.INACTIVE,
+                JobStatus.QUEUED,
+                JobStatus.RUNNING,
+                JobStatus.CANCELING,
+                JobStatus.CONVERTING_INPUT,
+                JobStatus.CONVERTING_OUTPUT,
+                JobStatus.FETCHING_INPUT,
+                JobStatus.PUSHING_OUTPUT,
+            ],
+        )
+        .count()
+    )
+
+    return {
+        'outstanding': outstanding,
+    }