gscan: information on hover.

lib/cylc/gui/gscan.py

@@ -31,11 +31,13 @@
 
 from cylc.cfgspec.globalcfg import GLOBAL_CFG
 from cylc.cfgspec.gcylc import gcfg
+from cylc.exceptions import PortFileError
 import cylc.flags
 from cylc.gui.legend import ThemeLegendWindow
 from cylc.gui.dot_maker import DotMaker
 from cylc.gui.util import get_icon, setup_icons, set_exception_hook_dialog
 from cylc.network.port_scan import scan_all
+from cylc.network.suite_state import StateSummaryClient
 from cylc.owner import USER
 from cylc.version import CYLC_VERSION
 from cylc.task_state import TASK_STATUSES_ORDERED, TASK_STATUS_RUNAHEAD
@@ -646,6 +648,30 @@ def _on_query_tooltip(self, widget, x, y, kbd_ctx, tooltip):
         if column.get_title() != "Status":
             tooltip.set_text(None)
             return False
+
+        # If hovering over a status indicator set tooltip to show most recent
+        # tasks.
+        dot_offset, dot_width = tuple(column.cell_get_position(
+            column.get_cell_renderers()[1]))
+        cell_index = (cell_x - dot_offset) // dot_width
+        if cell_index >= 0:
+            # NOTE: TreeViewColumn.get_cell_renderers() does not allways return
+            # cell renderers for the correct row.
+            info = re.findall(r'\D+\d+', model.get(iter_, 6)[0])
+            if cell_index >= len(info):
+                return False
+            state = info[cell_index].strip().split(' ')[0]
+
+            point_string = model.get(iter_, 5)[0]
+            tasks = self.updater.get_last_n_tasks(suite, host, state,
+                                                  point_string, 5)
+            tooltip.set_markup('<b>{state}</b>\n{tasks}'.format(
+                state=state,
+                tasks='\n'.join(tasks))
+            )
+            return True
+
+        # Set the tooltip to a generic status for this suite.
         state_texts = []
         status_column_info = 6
         state_text = model.get_value(iter_, status_column_info)
@@ -673,7 +699,7 @@ def _set_cell_pixbuf_state(self, column, cell, model, iter_, index_tuple):
             is_stopped = model.get_value(iter_, 2)
             info = re.findall(r'\D+\d+', state_info)
             if index < len(info):
-                state = info[index].rsplit(" ", 1)[0]
+                state = info[index].rsplit(" ", 1)[0].strip()
                 icon = self.dots.get_icon(state.strip(), is_stopped=is_stopped)
                 cell.set_property("visible", True)
             else:
@@ -918,6 +944,9 @@ class ScanAppUpdater(BaseScanUpdater):
 
     """Update the scan app."""
 
+    TIME_STRINGS = ['submitted_time_string', 'started_time_string',
+                    'finished_time_string']
+
     def __init__(self, hosts, suite_treemodel, suite_treeview, owner=None,
                  poll_interval=None):
         self.suite_treemodel = suite_treemodel
@@ -955,6 +984,44 @@ def clear_stopped_suites(self):
         self.stopped_hosts_suites_info.clear()
         gobject.idle_add(self.update)
 
+    def get_last_n_tasks(self, suite, host, task_state, point_string, n):
+        """Returns a list of the last 'n' tasks with the provided state for
+        the provided suite."""
+        # TODO: safety check
+
+        # Get task state summary information.
+        try:
+            tasks = StateSummaryClient(
+                suite, host=host).get_suite_state_summary()[1]
+        except PortFileError:
+            return ['<i>Cannot connect to suite.</i>']
+
+        # If point_string specified, remove entries at other point_strings.
+        to_remove = []
+        if point_string:
+            for task in tasks:
+                _, task_point_string = task.rsplit('.', 1)
+                if task_point_string != point_string:
+                    to_remove.append(task)
+        for task in to_remove:
+            del tasks[task]
+
+        # Get list of tasks that match the provided state.
+        ret = []
+        for task in tasks:
+            if tasks[task]['state'] == task_state:
+                time_strings = ['1970-01-01T00:00:00Z']
+                for time_string in self.TIME_STRINGS:
+                    if time_string in tasks[task] and tasks[task][time_string]:
+                        time_strings.append(tasks[task][time_string])
+                ret.append((max(time_strings), task))
+
+        # return only the n youngest items
+        ret.sort(reverse=True)
+        suffix = [] if len(ret) <= n else [
+            '<i>And %d more</i>' % (len(ret) - n,)]
+        return [task[1] for task in ret[0:n]] + suffix
+
     def update(self):
         """Update the Applet."""
         row_ids = self._get_user_expanded_row_ids()