set default log file by job outcome (#2025)

set default log file by job outcome

Additionally:

* UID Tokens validates job part and permits `NN`
* Validate relative ID input in log view
* Log view: make file input non-clearable - The clear icon takes up space and can cover the filename. I can't think of a reason why a user would want to clear this particular input.
* Log view: ensure default job log file does not override `initialOptions`

---------

Co-authored-by: Ronnie Dutta <[email protected]>

Author: 2 people

changes.d/2025.feat.md

@@ -0,0 +1 @@
+Added conditional default log file based on job outcome

src/components/cylc/Job.vue

@@ -32,6 +32,7 @@ const Job = (props, context) => {
   const DEFAULT_XY = '10'
   const PREVIOUS_STATE_ITEMS_XY = '25'
   const width = !isEmpty(props.previousState) ? PREVIOUS_STATE_ITEMS_SIZE : DEFAULT_SIZE
+  const cJobClass = ['c-job', props.status]
   const jobStatusIcon = h(
     'rect',
     {
@@ -70,7 +71,7 @@ const Job = (props, context) => {
   if (props.svg) {
     return h(
       'g',
-      { class: 'c-job' },
+      { class: cJobClass },
       [
         h('g', { class: 'job' }, jobIconChildren)
       ]
@@ -86,7 +87,7 @@ const Job = (props, context) => {
   )
   return h(
     'span',
-    { class: 'c-job' },
+    { class: cJobClass },
     [jobIconSvg]
   )
 }

src/components/cylc/commandMenu/Menu.vue

@@ -128,6 +128,25 @@ import { eventBus } from '@/services/eventBus'
 import CopyBtn from '@/components/core/CopyBtn.vue'
 import { upperFirst } from 'lodash-es'
 import { formatFlowNums } from '@/utils/tasks'
+import { getJobLogFileFromState } from '@/model/JobState.model'
+
+/**
+ * Return the appropriate log file for a job or task node, or nothing for other nodes.
+ *
+ * @param {Object} node - Cylc object node (i.e. workflow, cycle, family, task or job)
+ */
+export function getLogFileForNode (node) {
+  let jobState
+  if (node.type === 'job') {
+    jobState = node.node.state
+  } else if (node.type === 'task') {
+    // Choose latest job (jobs are sorted by submit num descending in the store)
+    jobState = node.children[0]?.node.state
+  } else {
+    return
+  }
+  return getJobLogFileFromState(jobState)
+}
 
 export default {
   name: 'CommandMenu',
@@ -271,7 +290,8 @@ export default {
             {
               name: 'Log',
               initialOptions: {
-                relativeID: this.node.tokens.relativeID || null
+                relativeID: this.node.tokens.relativeID || null,
+                file: getLogFileForNode(this.node),
               }
             }
           )

src/model/JobState.model.js

@@ -42,4 +42,23 @@ class JobState extends Enumify {
 
 export const JobStateNames = JobState.enumValues.map(({ name }) => name)
 
+/**
+ * Get the appropriate log file name for a job based on its state.
+ *
+ * @param {string=} state
+ * @returns {string=} log file name if state is defined & valid, else undefined.
+ */
+export function getJobLogFileFromState (state) {
+  switch (state) {
+    case JobState.FAILED.name:
+      return 'job.err'
+    case JobState.SUBMITTED.name:
+    case JobState.SUBMIT_FAILED.name:
+      return 'job-activity.log'
+    case JobState.RUNNING.name:
+    case JobState.SUCCEEDED.name:
+      return 'job.out'
+  }
+}
+
 export default JobState

src/plugins/vuetify.js

@@ -42,7 +42,7 @@ const inputDefaults = Object.fromEntries(
       density: 'compact',
       variant: 'outlined',
       clearIcon: mdiClose,
-      hideDetails: true,
+      hideDetails: 'auto',
     }
   ])
 )

src/services/mock/json/index.cjs

@@ -1,4 +1,4 @@
-/**
+/*
  * Copyright (C) NIWA & British Crown (Met Office) & Contributors.
  *
  * This program is free software: you can redistribute it and/or modify
@@ -18,31 +18,25 @@
 const IntrospectionQuery = require('./IntrospectionQuery.json')
 const taskProxy = require('./taskProxy.json')
 const familyProxy = require('./familyProxy.json')
-const workflowOne = require('./workflows/one')
-const workflowsMulti = require('./workflows/multi')
+const { one, workflows, Workflow } = require('./workflows/index.cjs')
 const { LogData } = require('./logData.cjs')
-const { LogFiles } = require('./logFiles.cjs')
+const { LogFiles, JobState } = require('./logFiles.cjs')
 const analysisQuery = require('./analysisQuery.json')
 const ganttQuery = require('./ganttQuery.json')
 const InfoViewSubscription = require('./infoView.json')
 
-const workflows = [workflowOne, ...workflowsMulti]
-const analysisTaskQuery = analysisQuery.taskQuery
-const analysisJobQuery = analysisQuery.jobQuery
-
 module.exports = {
   IntrospectionQuery,
   taskProxy,
   familyProxy,
   LogData,
   LogFiles,
+  JobState,
   App: workflows,
-  Workflow ({ workflowId }) {
-    return workflows.find(({ deltas }) => deltas.id === workflowId) || {}
-  },
-  Test: workflowOne,
-  analysisTaskQuery,
-  analysisJobQuery,
+  Workflow,
+  GraphIQLTest: one,
+  analysisTaskQuery: analysisQuery.taskQuery,
+  analysisJobQuery: analysisQuery.jobQuery,
   analysisQuery,
   ganttQuery,
   InfoViewSubscription

src/services/mock/json/logFiles.cjs

@@ -1,4 +1,4 @@
-/**
+/*
  * Copyright (C) NIWA & British Crown (Met Office) & Contributors.
  *
  * This program is free software: you can redistribute it and/or modify
@@ -16,13 +16,15 @@
  */
 
 const { simulatedDelay } = require('./util.cjs')
+const { Workflow } = require('./workflows/index.cjs')
 
 const deletedFile = 'deleted.log'
 
 const jobLogFiles = [
   'job.out',
   'job.err',
   'job',
+  'job-activity.log',
 ]
 
 const workflowLogFiles = [
@@ -48,7 +50,32 @@ const LogFiles = async ({ id }) => {
   }
 }
 
+/**
+ * Return a mock GQL response for job state.
+ *
+ * @param {{ id: string }} variables
+ */
+const JobState = async ({ id, workflowId }) => {
+  if (!workflowId.startsWith('~')) {
+    workflowId = `~user/${workflowId}`
+  }
+  const { deltas } = Workflow({ workflowId })
+  const searchID = id.replace(
+    /\/NN$/, ''
+  ).replace(
+    /\/(\d+)$/, (match, p1) => `/${parseInt(p1)}` // strips leading zeroes
+  )
+  const { state } = deltas?.added?.jobs?.find((job) => job.id.includes(searchID)) ?? {}
+  await simulatedDelay(500)
+  return {
+    data: {
+      jobs: state ? [{ id, state }] : []
+    }
+  }
+}
+
 module.exports = {
+  JobState,
   LogFiles,
   deletedFile,
   jobLogFiles,

src/services/mock/json/workflows/index.cjs

@@ -0,0 +1,31 @@
+/*
+ * Copyright (C) NIWA & British Crown (Met Office) & Contributors.
+ *
+ * This program is free software: you can redistribute it and/or modify
+ * it under the terms of the GNU General Public License as published by
+ * the Free Software Foundation, either version 3 of the License, or
+ * (at your option) any later version.
+ *
+ * This program is distributed in the hope that it will be useful,
+ * but WITHOUT ANY WARRANTY; without even the implied warranty of
+ * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
+ * GNU General Public License for more details.
+ *
+ * You should have received a copy of the GNU General Public License
+ * along with this program.  If not, see <http://www.gnu.org/licenses/>.
+ */
+
+const one = require('./one')
+const multi = require('./multi')
+
+const workflows = [one, ...multi]
+
+function Workflow ({ workflowId }) {
+  return workflows.find(({ deltas }) => deltas.id === workflowId) || {}
+}
+
+module.exports = {
+  one,
+  workflows,
+  Workflow,
+}

src/utils/uid.js

@@ -1,4 +1,4 @@
-/**
+/*
  * Copyright (C) NIWA & British Crown (Met Office) & Contributors.
  *
  * This program is free software: you can redistribute it and/or modify
@@ -123,6 +123,8 @@ const RELATIVE_ID = new RegExp(`
 
 /* eslint-enable */
 
+const JOB_ID = /^(\d+|NN)$/
+
 function detokenise (tokens, workflow = true, relative = true) {
   let parts = []
   let ret = ''
@@ -159,7 +161,7 @@ function detokenise (tokens, workflow = true, relative = true) {
   return ret
 }
 
-class Tokens {
+export class Tokens {
   /* Represents a Cylc UID.
    *
    * Provides the interfaces for parsing to and from string IDs.
@@ -262,19 +264,29 @@ class Tokens {
       this.job = undefined
     }
 
+    if (this.job && !JOB_ID.test(this.job)) {
+      throw new Error(`Invalid job ID: ${this.job}`)
+    }
+
     this.workflowID = detokenise(this, true, false)
     this.relativeID = detokenise(this, false, true)
   }
 
   set (fields) {
-    for (const [key, value] of Object.entries(fields)) {
-      if (Tokens.KEYS.indexOf(key) === -1) {
-        throw new Error(`Invalid key: ${key}`)
+    if (fields instanceof Tokens) {
+      for (const key of Tokens.KEYS) {
+        if (fields[key]) this[key] = fields[key]
       }
-      if (typeof value !== 'string' && typeof value !== 'undefined') {
-        throw new Error(`Invalid type for value: ${value}`)
+    } else {
+      for (const [key, value] of Object.entries(fields)) {
+        if (!Tokens.KEYS.includes(key)) {
+          throw new Error(`Invalid key: ${key}`)
+        }
+        if (typeof value !== 'string' && value != null) {
+          throw new Error(`Invalid type for value: ${value}`)
+        }
+        this[key] = value ?? undefined
       }
-      this[key] = value
     }
     this.compute()
   }
@@ -360,6 +372,19 @@ class Tokens {
     }
     return ret
   }
-}
 
-export { Tokens }
+  /**
+   * Validate an ID string without throwing an error.
+   *
+   * @param {string} id
+   * @returns {string=} Error message if invalid, otherwise nothing.
+   */
+  static validate (id, relative = false) {
+    try {
+      // eslint-disable-next-line no-new
+      new Tokens(id, relative)
+    } catch (e) {
+      return e.message
+    }
+  }
+}