(self, ctx, experiment, plugin_names, run, tag)
| 180 | return result |
| 181 | |
| 182 | def _read_blob(self, ctx, experiment, plugin_names, run, tag): |
| 183 | for plugin_name in plugin_names: |
| 184 | blob_sequences = self._data_provider.read_blob_sequences( |
| 185 | ctx, |
| 186 | experiment_id=experiment, |
| 187 | plugin_name=plugin_name, |
| 188 | run_tag_filter=provider.RunTagFilter(runs=[run], tags=[tag]), |
| 189 | downsample=1, |
| 190 | ) |
| 191 | blob_sequence_data = blob_sequences.get(run, {}).get(tag, ()) |
| 192 | try: |
| 193 | blob_ref = blob_sequence_data[0].values[0] |
| 194 | except IndexError: |
| 195 | continue |
| 196 | return self._data_provider.read_blob( |
| 197 | ctx, blob_key=blob_ref.blob_key |
| 198 | ) |
| 199 | raise errors.NotFoundError() |
| 200 | |
| 201 | def graph_impl( |
| 202 | self, |
no test coverage detected