Fix for the issue #421 ViewCmd.java

seqeralabs · Sep 4, 2024 · bbd4890 · bbd4890
1 parent 79ce71d
commit bbd4890
Showing 1 changed file with 9 additions and 7 deletions.
diff --git a/src/main/java/io/seqera/tower/cli/commands/runs/ViewCmd.java b/src/main/java/io/seqera/tower/cli/commands/runs/ViewCmd.java
@@ -145,23 +145,25 @@ protected Response exec() throws ApiException {
             Map<String, Object> stats = new HashMap<>();
             if (opts.stats) {
                 stats.put("wallTime", TimeUnit.MILLISECONDS.toSeconds(workflow.getDuration()) / 60D);
-                stats.put("cpuTime", TimeUnit.MILLISECONDS.toMinutes(progress.getWorkflowProgress().getCpuTime()) / 60D);
-                stats.put("totalMemory", progress.getWorkflowProgress().getMemoryRss() / 1024 / 1024 / 1024D);
-                stats.put("read", progress.getWorkflowProgress().getReadBytes() / 1024 / 1024 / 1024D);
-                stats.put("write", progress.getWorkflowProgress().getWriteBytes() / 1024 / 1024 / 1024D);
-                stats.put("cost", progress.getWorkflowProgress().getCost());
+                if(progress.getWorkflowProgress() != null) {
+                    stats.put("cpuTime", TimeUnit.MILLISECONDS.toMinutes(progress.getWorkflowProgress().getCpuTime()) / 60D);
+                    stats.put("totalMemory", progress.getWorkflowProgress().getMemoryRss() / 1024 / 1024 / 1024D);
+                    stats.put("read", progress.getWorkflowProgress().getReadBytes() / 1024 / 1024 / 1024D);
+                    stats.put("write", progress.getWorkflowProgress().getWriteBytes() / 1024 / 1024 / 1024D);
+                    stats.put("cost", progress.getWorkflowProgress().getCost());
+                }
             }
 
             Map<String, Object> load = new HashMap<>();
-            if (opts.load) {
+            if (opts.load && progress.getWorkflowProgress() != null) {
                 load.put("peakCpus", progress.getWorkflowProgress().getPeakCpus());
                 load.put("loadCpus", progress.getWorkflowProgress().getLoadCpus());
                 load.put("peakTasks", progress.getWorkflowProgress().getPeakTasks());
                 load.put("loadTasks", progress.getWorkflowProgress().getLoadTasks());
             }
 
             Map<String, Object> utilization = new HashMap<>();
-            if (opts.utilization) {
+            if (opts.utilization && progress.getWorkflowProgress() != null) {
                 utilization.put("memoryEfficiency", progress.getWorkflowProgress().getMemoryEfficiency());
                 utilization.put("cpuEfficiency", progress.getWorkflowProgress().getCpuEfficiency());
             }