Skip to content

Commit 14632f6

Browse files
author
Guillaume Charbonnier
committed
introduce last_active in SequenceInfo
Signed-off-by: Guillaume Charbonnier <[email protected]>
1 parent 7a49679 commit 14632f6

File tree

1 file changed

+12
-2
lines changed

1 file changed

+12
-2
lines changed

nats/js/api.py

Lines changed: 12 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -469,8 +469,18 @@ def as_dict(self) -> Dict[str, object]:
469469
class SequenceInfo(Base):
470470
consumer_seq: int
471471
stream_seq: int
472-
# FIXME: Do not handle dates for now.
473-
# last_active: Optional[datetime]
472+
last_active: Optional[datetime.datetime] = None
473+
474+
@classmethod
475+
def from_response(cls, resp: Dict[str, Any]):
476+
cls._convert_rfc3339(resp, 'last_active')
477+
return super().from_response(resp)
478+
479+
def as_dict(self) -> Dict[str, object]:
480+
result = super().as_dict()
481+
if self.last_active is not None:
482+
result['last_active'] = self._to_rfc3339(self.last_active)
483+
return result
474484

475485

476486
@dataclass

0 commit comments

Comments
 (0)