Add short_metrics

test/test_metrics.py

@@ -36,6 +36,54 @@ def test_clear_metrics(self):
     assert ("TensorToData" in met.metrics_report())
     assert (len(met.metric_names()) > 0)
 
+  def test_short_metrics_report_default_list(self):
+    xla_device = xm.xla_device()
+    t1 = torch.tensor(100, device=xla_device)
+    t2 = t1 * 2
+    xm.mark_step()
+    t2_cpu = t2.cpu()
+    short_report = met.short_metrics_report()
+    assert ("TensorToData" not in short_report)
+    assert ("CompileTime" in short_report)
+    assert ("ExecuteTime" in short_report)
+    assert ("TransferToServerTime" in short_report)
+    assert ("TransferFromServerTime" in short_report)
+    assert ("MarkStep" in short_report)
+    # repeat the same computation and expect to see the CachedCompile counter
+    t3 = t1 * 2
+    xm.mark_step()
+    t4 = t1 * 2
+    xm.mark_step()
+    assert ("CachedCompile" in short_report)
+
+  def test_short_metrics_report_custom_list(self):
+    xla_device = xm.xla_device()
+    t1 = torch.tensor(100, device=xla_device)
+    t2 = t1 * 2
+    xm.mark_step()
+    t2_cpu = t2.cpu()
+    short_report = met.short_metrics_report(
+        counter_names=['CreateCompileHandles'])
+    assert ('CreateCompileHandles' in short_report)
+    assert ('MarkStep' not in short_report)
+    # using the default metrics list in this case
+    assert ('CompileTime' in short_report)
+    short_report = met.short_metrics_report(
+        counter_names=['CreateCompileHandles'], metric_names=['InboundData'])
+    assert ('CompileTime' not in short_report)
+    assert ('InboundData' in short_report)
+
+  def test_short_metrics_fallback_counter(self):
+    xla_device = xm.xla_device()
+    t1 = torch.tensor(100, device=xla_device)
+    t2 = t1 * 2
+    # this will trigger a aten::_local_scalar_dense which is the same as fallback counter
+    if t2:
+      t2 += 1
+    assert ('aten::_local_scalar_dense' in met.short_metrics_report())
+    assert ('aten::_local_scalar_dense' in met.short_metrics_report(
+        counter_names=['CreateCompileHandles'], metric_names=['InboundData']))
+
 
 if __name__ == '__main__':
   test = unittest.main()

third_party/xla_client/metrics.cc

@@ -345,6 +345,33 @@ std::string CreateMetricReport() {
   return ss.str();
 }
 
+std::string CreateMetricReport(const std::vector<std::string>& counter_names,
+                               const std::vector<std::string>& metric_names) {
+  MetricsArena* arena = MetricsArena::Get();
+  std::stringstream ss;
+  for (const std::string& metric_name : metric_names) {
+    MetricData* data = arena->GetMetric(metric_name);
+    if (data && data->TotalSamples() > 0) {
+      EmitMetricInfo(metric_name, data, &ss);
+    }
+  }
+  for (const std::string& counter_name : counter_names) {
+    CounterData* data = arena->GetCounter(counter_name);
+    if (data && data->Value() > 0) {
+      EmitCounterInfo(counter_name, data, &ss);
+    }
+  }
+  static std::string fall_back_counter_prefix = "aten::";
+  arena->ForEachCounter([&ss](const std::string& name, CounterData* data) {
+    if (name.rfind(fall_back_counter_prefix, 0) == 0 && data->Value() > 0) {
+      // it might emit duplicated counter if user also specified exact aten
+      // counter in the `counter_names` but it should be very rare.
+      EmitCounterInfo(name, data, &ss);
+    }
+  });
+  return ss.str();
+}
+
 std::vector<std::string> GetMetricNames() {
   return MetricsArena::Get()->GetMetricNames();
 }

third_party/xla_client/metrics.h

@@ -196,6 +196,10 @@ class Counter {
 // Creates a report with the current metrics statistics.
 std::string CreateMetricReport();
 
+// Creates a report with the selected metrics statistics.
+std::string CreateMetricReport(const std::vector<std::string>& counter_names,
+                               const std::vector<std::string>& metric_names);
+
 // Returns the currently registered metric names. Note that the list can grow
 // since metrics are usualy function intialized (they are static function
 // variables).

third_party/xla_client/metrics_reader.cc

@@ -74,5 +74,10 @@ std::string CreateMetricReport() {
   return metrics::CreateMetricReport() + CreateXrtMetricReport();
 }
 
+std::string CreateMetricReport(const std::vector<std::string>& counter_names,
+                               const std::vector<std::string>& metric_names) {
+  return metrics::CreateMetricReport(counter_names, metric_names);
+}
+
 }  // namespace metrics_reader
 }  // namespace xla

third_party/xla_client/metrics_reader.h

@@ -2,13 +2,18 @@
 #define XLA_CLIENT_METRICS_READER_H_
 
 #include <string>
+#include <vector>
 
 namespace xla {
 namespace metrics_reader {
 
 // Creates a report with the current metrics statistics.
 std::string CreateMetricReport();
 
+// Creates a report with the selected metrics statistics.
+std::string CreateMetricReport(const std::vector<std::string>& counter_names,
+                               const std::vector<std::string>& metric_names);
+
 }  // namespace metrics_reader
 }  // namespace xla
 

torch_xla/csrc/init_python_bindings.cpp

@@ -1190,6 +1190,19 @@ void InitXlaModuleBindings(py::module m) {
   });
   m.def("_xla_metrics_report",
         []() { return xla::metrics_reader::CreateMetricReport(); });
+  m.def("_short_xla_metrics_report",
+        [](const py::list& counter_names, const py::list& metric_names) {
+          std::vector<std::string> counter_name_vec;
+          std::vector<std::string> metric_name_vec;
+          for (auto& counter : counter_names) {
+            counter_name_vec.push_back(counter.cast<std::string>());
+          }
+          for (auto& metric : metric_names) {
+            metric_name_vec.push_back(metric.cast<std::string>());
+          }
+          return xla::metrics_reader::CreateMetricReport(counter_name_vec,
+                                                         metric_name_vec);
+        });
   m.def("_clear_xla_counters", []() { xla::metrics::ClearCounters(); });
   m.def("_clear_xla_metrics", []() { xla::metrics::ClearMetrics(); });
   m.def("_xla_tensors_report",

torch_xla/debug/metrics.py

@@ -57,3 +57,20 @@ def clear_metrics():
 def metrics_report():
   """Retrieves a string containing the full metrics and counters report."""
   return torch_xla._XLAC._xla_metrics_report()
+
+
+def short_metrics_report(counter_names=None, metric_names=None):
+  """Retrieves a string containing the full metrics and counters report.
+
+  Args:
+    counter_names (list): The list of counter names whose data needs to be printed.
+    metric_names (list): The list of metric names whose data needs to be printed.
+  """
+  if counter_names == None:
+    counter_names = ['CachedCompile', 'MarkStep']
+  if metric_names == None:
+    metric_names = [
+        'CompileTime', 'ExecuteTime', 'TransferToServerTime',
+        'TransferFromServerTime'
+    ]
+  return torch_xla._XLAC._short_xla_metrics_report(counter_names, metric_names)