Skip to content
Snippets Groups Projects
Commit d7c332e4 authored by David Douard's avatar David Douard
Browse files

Update JournalClientOffsetRanges for swh.journal 0.9

deserialize_message() now takes an optional 'object_type' argument.
parent 31081e41
No related branches found
No related tags found
No related merge requests found
# Add here internal Software Heritage dependencies, one per line.
swh.core[http] >= 2
swh.journal
swh.journal >= 0.9
swh.model >= 4.3
swh.storage
......@@ -105,7 +105,7 @@ class JournalClientOffsetRanges(JournalClient):
self._messages_to_commit.append(message)
self.unsubscribe([partition_id])
def deserialize_message(self, message):
def deserialize_message(self, message, object_type=None):
"""
Override of the message deserialization to hook the handling of the
message offset.
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment