Skip to content

Commit c465579

Browse files
committed
APP-6766: Prevent pagination loop break by filtering invalid assets
https://atlanhq.atlassian.net/browse/APP-6766?focusedCommentId=405395
1 parent a130816 commit c465579

File tree

3 files changed

+3
-3
lines changed

3 files changed

+3
-3
lines changed

pyatlan/client/asset.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1929,8 +1929,8 @@ def _get_next_page_json(self, is_bulk_search: bool = False):
19291929
try:
19301930
self._process_entities(raw_json["entities"])
19311931
if is_bulk_search:
1932-
self._update_first_last_record_creation_times()
19331932
self._filter_processed_assets()
1933+
self._update_first_last_record_creation_times()
19341934
return raw_json
19351935

19361936
except ValidationError as err:

pyatlan/model/audit.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -341,8 +341,8 @@ def _get_next_page_json(self, is_bulk_search: bool = False):
341341
List[EntityAudit], raw_json[ENTITY_AUDITS]
342342
)
343343
if is_bulk_search:
344-
self._update_first_last_record_creation_times()
345344
self._filter_processed_entities()
345+
self._update_first_last_record_creation_times()
346346
return raw_json
347347
except ValidationError as err:
348348
raise ErrorCode.JSON_ERROR.exception_with_parameters(

pyatlan/model/search_log.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -502,8 +502,8 @@ def _get_next_page_json(self, is_bulk_search: bool = False):
502502
try:
503503
self._log_entries = parse_obj_as(List[SearchLogEntry], raw_json["logs"])
504504
if is_bulk_search:
505-
self._update_first_last_record_creation_times()
506505
self._filter_processed_entities()
506+
self._update_first_last_record_creation_times()
507507
return raw_json
508508
except ValidationError as err:
509509
raise ErrorCode.JSON_ERROR.exception_with_parameters(

0 commit comments

Comments
 (0)