diff --git a/faust/tables/wrappers.py b/faust/tables/wrappers.py index 0aeb3b974..659223936 100644 --- a/faust/tables/wrappers.py +++ b/faust/tables/wrappers.py @@ -445,7 +445,7 @@ def __len__(self) -> int: if self.key_index_table is not None: return len(self.key_index_table) raise NotImplementedError( - 'Windowed table must use_index=True to support len()') + 'Windowed table must set key_index=True to support len()') def _relative_handler( self, relative_to: RelativeArg) -> Optional[RelativeHandler]: @@ -476,7 +476,7 @@ def _keys(self) -> Iterator: yield key else: raise NotImplementedError( - 'Windowed table must set use_index=True to ' + 'Windowed table must set key_index=True to ' 'support .keys/.items/.values') def values(self, event: EventT = None) -> ValuesView: