Merge pull request #797 from atlanhq/BLDX-460

[release] Bumped to release `8.5.1`

Author: Aryamanz29

HISTORY.md

@@ -1,4 +1,16 @@
-## 8.5.0 (January 14, 2025)
+## 8.5.1 (January 29, 2026)
+
+### Bug Fixes
+
+- Fixed iterative pagination in User and Role caches that prevented all records from being properly populated during cache refresh operations.
+
+### QOL Improvements
+
+- Enhanced SDK client retry mechanism to automatically retry HTTP `302` redirect responses, improving reliability when handling temporary redirects.
+- Updated admin integration tests to align with latest backend API changes.
+  
+
+## 8.5.0 (January 14, 2026)
 
 ### New Features
 
@@ -9,7 +21,7 @@
 - `DataQualityRule.table_level_rule_creator()` and `DataQualityRule.column_level_rule_creator()` now accept `rule_type` as a `DataQualityRuleTemplateType` enum instead of `str`.
 - `threshold_compare_operator` is now an optional parameter for `DataQualityRule.table_level_rule_creator()`.
 
-## 8.4.6 (January 13, 2025)
+## 8.4.6 (January 13, 2026)
 
 ### New Features
 

pyatlan/cache/aio/group_cache.py

@@ -82,13 +82,11 @@ async def refresh_cache(self) -> None:
 
     async def _refresh_cache(self) -> None:
         async with self.lock:
-            groups = await self.client.group.get_all()
+            groups = [group async for group in await self.client.group.get_all()]
             if not groups:
                 return
-            # Process response using shared logic - extract records from response
-            group_list = groups.records or []
             (self.map_id_to_name, self.map_name_to_id, self.map_alias_to_id) = (
-                GroupCacheCommon.refresh_cache_data(group_list)
+                GroupCacheCommon.refresh_cache_data(groups)
             )
 
     async def _get_id_for_name(self, name: str) -> Optional[str]:

pyatlan/cache/aio/user_cache.py

@@ -74,13 +74,11 @@ async def refresh_cache(self) -> None:
 
     async def _refresh_cache(self) -> None:
         async with self.lock:
-            users = await self.client.user.get_all()
+            users = [user async for user in await self.client.user.get_all()]
             if not users:
                 return
-            # Process response using shared logic - extract records from response
-            user_list = users.records or []
             (self.map_id_to_name, self.map_name_to_id, self.map_email_to_id) = (
-                UserCacheCommon.refresh_cache_data(user_list)
+                UserCacheCommon.refresh_cache_data(users)
             )
 
     async def _get_id_for_name(self, name: str) -> Optional[str]:

pyatlan/cache/group_cache.py

@@ -64,13 +64,11 @@ def validate_aliases(self, aliases: Iterable[str]):
 
     def _refresh_cache(self) -> None:
         with self.lock:
-            groups = self.client.group.get_all()
+            groups = [group for group in self.client.group.get_all()]
             if not groups:
                 return
-            # Process response using shared logic - extract records from response
-            group_list = groups.records or []
             (self.map_id_to_name, self.map_name_to_id, self.map_alias_to_id) = (
-                GroupCacheCommon.refresh_cache_data(group_list)
+                GroupCacheCommon.refresh_cache_data(groups)
             )
 
     def _get_id_for_name(self, name: str) -> Optional[str]:

pyatlan/cache/user_cache.py

@@ -64,13 +64,11 @@ def validate_names(self, names: Iterable[str]):
 
     def _refresh_cache(self) -> None:
         with self.lock:
-            users = self.client.user.get_all()
+            users = [user for user in self.client.user.get_all()]
             if not users:
                 return
-            # Process response using shared logic - extract records from response
-            user_list = users.records or []
             (self.map_id_to_name, self.map_name_to_id, self.map_email_to_id) = (
-                UserCacheCommon.refresh_cache_data(user_list)
+                UserCacheCommon.refresh_cache_data(users)
             )
 
     def _get_id_for_name(self, name: str) -> Optional[str]:

pyatlan/client/atlan.py

@@ -111,7 +111,7 @@ def get_adapter() -> logging.LoggerAdapter:
 DEFAULT_RETRY = Retry(
     total=5,
     backoff_factor=1,
-    status_forcelist=[403, 429, 500, 502, 503, 504],
+    status_forcelist=[302, 403, 429, 500, 502, 503, 504],
     allowed_methods=["HEAD", "GET", "OPTIONS", "POST", "PUT", "DELETE"],
     # When response.status is in `status_forcelist`
     # and the "Retry-After" header is present, the retry mechanism

pyatlan/version.txt

@@ -1 +1 @@
-8.5.0
+8.5.1

tests/integration/admin_test.py

@@ -149,8 +149,7 @@ def test_group_get_members_pagination(client: AtlanClient, group: CreateGroupRes
     assert len(current_page) == 1
     for test_user in response:
         assert test_user.username
-        assert test_user.email
-        assert test_user.attributes
+        assert test_user.enabled
     current_page = response.current_page()
     assert current_page is not None
     assert len(current_page) == 0
@@ -167,8 +166,7 @@ def test_user_list_pagination(client: AtlanClient, group: CreateGroupResponse):
     assert len(current_page) == 1
     for test_user in response:
         assert test_user.username
-        assert test_user.email
-        assert test_user.attributes
+        assert test_user.enabled
         assert test_user.login_events is not None
         assert len(test_user.login_events) >= 0
     current_page = response.current_page()
@@ -247,7 +245,6 @@ def test_retrieve_existing_user(client: AtlanClient, group: CreateGroupResponse)
     user1 = client.user.get_by_username(FIXED_USER)
     assert user1
     assert user1.id
-    assert user1.attributes
     assert user1.group_count == 1 + _default_group_count
     response = client.user.get_by_usernames(usernames=[FIXED_USER])
     assert response

tests/integration/aio/test_admin.py

@@ -160,8 +160,7 @@ async def test_group_get_members_pagination(
     assert len(current_page) == 1
     async for test_user in response:
         assert test_user.username
-        assert test_user.email
-        assert test_user.attributes
+        assert test_user.enabled
     current_page = response.current_page()
     assert current_page is not None
     assert len(current_page) == 0
@@ -180,8 +179,7 @@ async def test_user_list_pagination(
     assert len(current_page) == 1
     async for test_user in response:
         assert test_user.username
-        assert test_user.email
-        assert test_user.attributes
+        assert test_user.enabled
         assert test_user.login_events is not None
         assert len(test_user.login_events) >= 0
     current_page = response.current_page()
@@ -266,7 +264,6 @@ async def test_retrieve_existing_user(
     user1 = await client.user.get_by_username(FIXED_USER)
     assert user1
     assert user1.id
-    assert user1.attributes
     assert user1.group_count == 1 + _default_group_count
     response = await client.user.get_by_usernames(usernames=[FIXED_USER])
     assert response