diff --git a/btrdb/stream.py b/btrdb/stream.py index e9d4ac5..e1cd2d7 100644 --- a/btrdb/stream.py +++ b/btrdb/stream.py @@ -823,7 +823,7 @@ def _update_tags_collection(self, tags, collection): """ :meta private: """ - tags = self.tags() if tags is None else tags + tags = {} if tags is None else tags collection = self.collection if collection is None else collection if collection is None: raise BTRDBValueError( diff --git a/tests/btrdb/test_stream.py b/tests/btrdb/test_stream.py index 4fede74..5887afa 100644 --- a/tests/btrdb/test_stream.py +++ b/tests/btrdb/test_stream.py @@ -272,15 +272,14 @@ def test_update_collection(self): endpoint = Mock(Endpoint) endpoint.streamInfo = Mock(return_value=("koala", 42, {}, {}, None)) endpoint.info = Mock(return_value={"majorVersion": 5, "minorVersion": 30}) - stream = Stream(btrdb=BTrDB(endpoint), uuid=uu) + stream = Stream(btrdb=BTrDB(endpoint), uuid=uu, property_version=42) collection = "giraffe" stream.update(collection=collection) stream._btrdb.ep.setStreamTags.assert_called_once_with( - uu=uu, expected=42, tags=stream.tags(), collection=collection + uu=uu, expected=42, tags={}, collection=collection ) - stream._btrdb.ep.setStreamAnnotations.assert_not_called() def test_update_annotations(self): """