Skip to content

Commit

Permalink
fix typos
Browse files Browse the repository at this point in the history
  • Loading branch information
ryandeivert committed Sep 23, 2022
1 parent ba6aa66 commit 0189976
Showing 1 changed file with 4 additions and 4 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -12,22 +12,22 @@ def shard_id(self) -> Optional[str]:
return self.get("shardId")

@property
def partition_key(self) -> Optional[str]
def partition_key(self) -> Optional[str]:
"""Kinesis stream partition key; present only when Kinesis Stream is source"""
return self.get("partitionKey")

@property
def approximate_arrival_timestamp(self) -> Optional[str]
def approximate_arrival_timestamp(self) -> Optional[str]:
"""Kinesis stream approximate arrival ISO timestamp; present only when Kinesis Stream is source"""
return self.get("approximateArrivalTimestamp")

@property
def sequence_number(self) -> Optional[str]
def sequence_number(self) -> Optional[str]:
"""Kinesis stream sequence number; present only when Kinesis Stream is source"""
return self.get("sequenceNumber")

@property
def subsequence_number(self) -> Optional[str]
def subsequence_number(self) -> Optional[str]:
"""Kinesis stream sub-sequence number; present only when Kinesis Stream is source
Note: this will only be present for Kinesis streams using record aggregation
Expand Down

0 comments on commit 0189976

Please sign in to comment.