From ab5ea9b421394a397f539a2ac856a367e67deccb Mon Sep 17 00:00:00 2001 From: alexanderoberegger Date: Tue, 16 Feb 2021 21:20:59 +0100 Subject: [PATCH 1/2] check assigned topic name for a changelog --- faust/stores/rocksdb.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/faust/stores/rocksdb.py b/faust/stores/rocksdb.py index 649e56991..a2d45b66a 100644 --- a/faust/stores/rocksdb.py +++ b/faust/stores/rocksdb.py @@ -454,7 +454,7 @@ def _dbs_for_key(self, key: bytes) -> Iterable[DB]: def _dbs_for_actives(self) -> Iterator[DB]: actives = self.app.assignor.assigned_actives() - topic = self.table._changelog_topic_name() + topic = self.table.changelog_topic_name for partition, db in self._dbs.items(): tp = TP(topic=topic, partition=partition) # for global tables, keys from all From cacf032899e7f9ceba6f21631cdd732a4fe6a96b Mon Sep 17 00:00:00 2001 From: alexanderoberegger Date: Tue, 16 Feb 2021 21:46:01 +0100 Subject: [PATCH 2/2] fix testcase to mock property --- tests/unit/stores/test_rocksdb.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/tests/unit/stores/test_rocksdb.py b/tests/unit/stores/test_rocksdb.py index 69d665799..c32164cdd 100644 --- a/tests/unit/stores/test_rocksdb.py +++ b/tests/unit/stores/test_rocksdb.py @@ -427,7 +427,7 @@ def test__dbs_for_key(self, *, store): assert list(store._dbs_for_key(b"key")) == [dbs[2]] def test__dbs_for_actives(self, *, store, table): - table._changelog_topic_name.return_value = "clog" + table.changelog_topic_name = "clog" store.app.assignor.assigned_actives = Mock( return_value=[ TP("clog", 1),