Skip to content

Commit

Permalink
Merge pull request #3 from MeltanoLabs/set_is_sorted
Browse files Browse the repository at this point in the history
set is_sorted to true to allow resuming
  • Loading branch information
pnadolny13 committed Jan 18, 2023
2 parents 63b0eac + e743ddf commit 3a6250f
Showing 1 changed file with 14 additions and 0 deletions.
14 changes: 14 additions & 0 deletions tap_cloudwatch/client.py
Original file line number Diff line number Diff line change
Expand Up @@ -10,6 +10,20 @@
class CloudWatchStream(Stream):
"""Stream class for CloudWatch streams."""

@property
def is_sorted(self) -> bool:
"""Expect stream to be sorted.
When `True`, incremental streams will attempt to resume if unexpectedly
interrupted.
Returns
-------
`True` if stream is sorted. Defaults to `False`.
"""
return True

def get_records(self, context: Optional[dict]) -> Iterable[dict]:
"""Return a generator of record-type dictionary objects.
Expand Down

0 comments on commit 3a6250f

Please sign in to comment.