Skip to content

Commit

Permalink
[ChangeFeed]Tweak one test and re-record (#15991)
Browse files Browse the repository at this point in the history
* [ChangeFeed]Tweak one test and re-record

* fix CI failure
  • Loading branch information
xiafu-msft authored Jan 6, 2021
1 parent 4510537 commit c04396e
Show file tree
Hide file tree
Showing 3 changed files with 487,563 additions and 73,650 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -179,7 +179,11 @@ def _get_next_segment(self, segment_path, page_size, segment_cursor=None):
return None

def _get_segment_paths(self, start_year=""):
cur_year = datetime.today().year
try:
cur_year = self.end_time.year
except AttributeError:
cur_year = datetime.today().year

while not start_year or start_year <= cur_year:
paths = self.client.list_blobs(name_starts_with=SEGMENT_COMMON_PATH + str(start_year))
for path in paths:
Expand Down
Loading

0 comments on commit c04396e

Please sign in to comment.