Skip to content
Snippets Groups Projects

Fix stacking buffer shape issue

Merged Egor Sobolev requested to merge fix/stacking-buffer-shape into master
3 unresolved threads
1 file
+ 2
0
Compare changes
  • Side-by-side
  • Inline
@@ -510,6 +510,8 @@ class ShmemTrainMatcher(TrainMatcher.TrainMatcher):
)
self._maybe_update_stacking_buffers(
stacking_data_shapes, fill_missed_data, new_sources_map)
for (new_source, key), msg in ignore_stacking.items():
self.log.WARN(f"Failed to stack {new_source}.{key}: {msg}")
if self._thread_pool is None:
for source, (data, timestamp) in sources.items():
Loading