hide user workers if not enabled (#1438)

.env.default

@@ -26,6 +26,7 @@ COMPOSE_PROJECT_NAME=dive
 # the user requires administrator permissions in rabbitmq management plugin
 # it is probably a different user than the celery login user above.
 #
+#RABBITMQ_DISTRIBUTED_WORKER=0 # if the UI for distributed workers should be displayed
 #RABBITMQ_MANAGEMENT_USERNAME=guest
 #RABBITMQ_MANAGEMENT_PASSWORD=guest
 #RABBITMQ_MANAGEMENT_VHOST=default

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

@@ -16,6 +16,7 @@ export default defineComponent({
     const restClient = useGirderRest();
     const store = useStore();
     const outstandingJobs = ref(0);
+    const distributedWorkerEnabled = ref(false);
 
     watch(toRef(store.getters, 'Jobs/runningJobIds'), () => {
       restClient.get('job/queued').then(({ data }) => {
@@ -30,6 +31,10 @@ export default defineComponent({
       loading.value = false;
     }
 
+    restClient.get('dive_configuration').then((data) => {
+      distributedWorkerEnabled.value = !!(data.data.distributedWorker);
+    });
+
     restClient.fetchUser()
       .then((user) => {
         privateQueueEnabled.value = user.user_private_queue_enabled;
@@ -41,6 +46,7 @@ export default defineComponent({
 
     return {
       privateQueueEnabled,
+      distributedWorkerEnabled,
       loading,
       outstandingJobs,
       /* methods */
@@ -120,6 +126,7 @@ export default defineComponent({
         </v-card-text>
       </v-card>
       <v-card
+        v-if="distributedWorkerEnabled"
         outlined
       >
         <v-card-title>

docker-compose.yml

@@ -46,6 +46,7 @@ services:
       - RABBITMQ_DEFAULT_USER=${RABBITMQ_DEFAULT_USER:-guest}
       - RABBITMQ_DEFAULT_PASS=${RABBITMQ_DEFAULT_PASS:-guest}
       - RABBITMQ_DEFAULT_VHOST=${RABBITMQ_DEFAULT_VHOST:-default}
+      - RABBITMQ_DISTRIBUTED_WORKER=${RABBITMQ_DISTRIBUTED_WORKER:-0}
 
   mongo:
     image: mongo:5.0

server/dive_server/views_configuration.py

@@ -49,6 +49,7 @@ def __init__(self, resourceName):
         super(ConfigurationResource, self).__init__()
         self.resourceName = resourceName
 
+        self.route("GET", (), self.get_config)
         self.route("GET", ("addons",), self.get_addons)
         self.route("GET", ("brand_data",), self.get_brand_data)
         self.route("GET", ("pipelines",), self.get_pipelines)
@@ -60,6 +61,16 @@ def __init__(self, resourceName):
 
         self.route("POST", ("upgrade_pipelines",), self.upgrade_pipelines)
 
+    @access.public
+    @autoDescribeRoute(Description("Get Configuration Information"))
+    def get_config(self):
+        env = os.environ.copy()
+
+        distributed_worker = env.get("RABBITMQ_DISTRIBUTED_WORKER")
+        return {
+            'distributedWorker': distributed_worker
+        }
+
     @access.public
     @autoDescribeRoute(Description("Get custom brand data"))
     def get_brand_data(self):