diff --git a/tensorboard/plugins/debugger_v2/debug_data_multiplexer.py b/tensorboard/plugins/debugger_v2/debug_data_multiplexer.py index 87bc0fb3e4..99de58cd91 100644 --- a/tensorboard/plugins/debugger_v2/debug_data_multiplexer.py +++ b/tensorboard/plugins/debugger_v2/debug_data_multiplexer.py @@ -297,14 +297,10 @@ def ExecutionData(self, run, begin, end): runs = self.Runs() if run not in runs: return None - # TODO(cais): For scalability, use begin and end kwargs when available in - # `DebugDataReader.execution()`.` execution_digests = self._reader.executions(digest=True) end = self._checkBeginEndIndices(begin, end, len(execution_digests)) execution_digests = execution_digests[begin:end] - executions = [ - self._reader.read_execution(digest) for digest in execution_digests - ] + executions = self._reader.executions(digest=False, begin=begin, end=end) return { "begin": begin, "end": end, @@ -366,15 +362,16 @@ def GraphExecutionData(self, run, begin, end, trace_id=None): "trace_id support for GraphExecutionTraceData is " "not implemented yet." ) - graph_executions = self._reader.graph_execution_traces(digest=False) - end = self._checkBeginEndIndices(begin, end, len(graph_executions)) + digests = self._reader.graph_execution_traces(digest=True) + end = self._checkBeginEndIndices(begin, end, len(digests)) + graph_executions = self._reader.graph_execution_traces( + digest=False, begin=begin, end=end + ) return { "begin": begin, "end": end, - "num_digests": len(graph_executions), "graph_executions": [ - graph_exec.to_json() - for graph_exec in graph_executions[begin:end] + graph_exec.to_json() for graph_exec in graph_executions ], }