Index: tracing/tracing/metrics/metric_runner.py |
diff --git a/tracing/tracing/metrics/metric_runner.py b/tracing/tracing/metrics/metric_runner.py |
index 910b7d66a335946e7a0b0510d0974d0e82389119..999e50711b6f314ca304de663bd992f201cf65b8 100644 |
--- a/tracing/tracing/metrics/metric_runner.py |
+++ b/tracing/tracing/metrics/metric_runner.py |
@@ -16,25 +16,28 @@ _METRIC_MAP_FUNCTION_NAME = 'metricMapFunction' |
def _GetMetricsDir(): |
return os.path.dirname(os.path.abspath(__file__)) |
-def _GetMetricRunnerHandle(metric): |
+def _GetMetricRunnerHandle(metric, iter_info): |
assert isinstance(metric, basestring) |
metrics_dir = _GetMetricsDir() |
metric_mapper_path = os.path.join(metrics_dir, _METRIC_MAP_FUNCTION_FILENAME) |
modules_to_load = [function_handle.ModuleToLoad(filename=metric_mapper_path)] |
+ options = {'metric': metric, 'iterInfo': iter_info} |
map_function_handle = function_handle.FunctionHandle( |
- modules_to_load, _METRIC_MAP_FUNCTION_NAME, {'metric': metric}) |
+ modules_to_load, _METRIC_MAP_FUNCTION_NAME, options) |
return job_module.Job(map_function_handle, None) |
-def RunMetric(filename, metric, extra_import_options=None): |
- result = RunMetricOnTraces([filename], metric, extra_import_options) |
+def RunMetric(filename, metric, iter_info=None, extra_import_options=None): |
+ result = RunMetricOnTraces([filename], metric, iter_info, |
+ extra_import_options) |
return result[filename] |
-def RunMetricOnTraces(filenames, metric, extra_import_options=None): |
+def RunMetricOnTraces(filenames, metric, iter_info=None, |
+ extra_import_options=None): |
trace_handles = [ |
file_handle.URLFileHandle(f, 'file://%s' % f) for f in filenames] |
- job = _GetMetricRunnerHandle(metric) |
+ job = _GetMetricRunnerHandle(metric, iter_info) |
runner = map_runner.MapRunner( |
trace_handles, job, |
extra_import_options=extra_import_options, |