diff --git a/src/streamstore/_mappers.py b/src/streamstore/_mappers.py index 68abb48..d6ed45c 100644 --- a/src/streamstore/_mappers.py +++ b/src/streamstore/_mappers.py @@ -36,7 +36,9 @@ def append_record_message(record: Record) -> msgs.AppendRecord: headers = [msgs.Header(name=name, value=value) for (name, value) in record.headers] - return msgs.AppendRecord(headers=headers, body=record.body) + return msgs.AppendRecord( + timestamp=record.timestamp, headers=headers, body=record.body + ) def append_input_message(stream: str, input: AppendInput) -> msgs.AppendInput: