|
70 | 70 | AssetRequest, |
71 | 71 | AssetResponse, |
72 | 72 | AtlanObject, |
73 | | - AtlanResponse, |
74 | 73 | AtlanTag, |
75 | 74 | AtlanTagName, |
76 | 75 | BulkRequest, |
@@ -247,10 +246,7 @@ def search(self, criteria: IndexSearchRequest, bulk=False) -> IndexSearchResults |
247 | 246 | unflatten_custom_metadata_for_entity( |
248 | 247 | entity=entity, attributes=criteria.attributes |
249 | 248 | ) |
250 | | - translated_entities = AtlanResponse( |
251 | | - raw_json=raw_json["entities"], client=self._client |
252 | | - ).to_dict() |
253 | | - assets = parse_obj_as(List[Asset], translated_entities) |
| 249 | + assets = parse_obj_as(List[Asset], raw_json["entities"]) |
254 | 250 | except ValidationError as err: |
255 | 251 | raise ErrorCode.JSON_ERROR.exception_with_parameters( |
256 | 252 | raw_json, 200, str(err) |
@@ -322,10 +318,7 @@ def get_lineage_list( |
322 | 318 | unflatten_custom_metadata_for_entity( |
323 | 319 | entity=entity, attributes=lineage_request.attributes |
324 | 320 | ) |
325 | | - translated_entities = AtlanResponse( |
326 | | - raw_json=raw_json["entities"], client=self._client |
327 | | - ).to_dict() |
328 | | - assets = parse_obj_as(List[Asset], translated_entities) |
| 321 | + assets = parse_obj_as(List[Asset], raw_json["entities"]) |
329 | 322 | has_more = parse_obj_as(bool, raw_json["hasMore"]) |
330 | 323 | except ValidationError as err: |
331 | 324 | raise ErrorCode.JSON_ERROR.exception_with_parameters( |
@@ -553,10 +546,7 @@ def _handle_relationships(self, raw_json): |
553 | 546 | raw_json["entity"]["relationshipAttributes"] |
554 | 547 | ) |
555 | 548 | raw_json["entity"]["relationshipAttributes"] = {} |
556 | | - translated_raw_json = AtlanResponse( |
557 | | - raw_json=raw_json, client=self._client |
558 | | - ).to_dict() |
559 | | - asset = AssetResponse[A](**translated_raw_json).entity |
| 549 | + asset = AssetResponse[A](**raw_json).entity |
560 | 550 | asset.is_incomplete = False |
561 | 551 | return asset |
562 | 552 |
|
@@ -640,10 +630,7 @@ def save( |
640 | 630 | asset.validate_required() |
641 | 631 | request = BulkRequest[Asset](entities=entities) |
642 | 632 | raw_json = self._client._call_api(BULK_UPDATE, query_params, request) |
643 | | - translated_raw_json = AtlanResponse( |
644 | | - raw_json=raw_json, client=self._client |
645 | | - ).to_dict() |
646 | | - response = AssetMutationResponse(**translated_raw_json) |
| 633 | + response = AssetMutationResponse(**raw_json) |
647 | 634 | if connections_created := response.assets_created(Connection): |
648 | 635 | self._wait_for_connections_to_be_created(connections_created) |
649 | 636 | return response |
@@ -2095,10 +2082,7 @@ def _process_entities(self, entities): |
2095 | 2082 | unflatten_custom_metadata_for_entity( |
2096 | 2083 | entity=entity, attributes=self._criteria.attributes |
2097 | 2084 | ) |
2098 | | - translated_entities = AtlanResponse( |
2099 | | - raw_json=entities, client=self._client |
2100 | | - ).to_dict() |
2101 | | - self._assets = parse_obj_as(List[Asset], translated_entities) |
| 2085 | + self._assets = parse_obj_as(List[Asset], entities) |
2102 | 2086 |
|
2103 | 2087 | def _update_first_last_record_creation_times(self): |
2104 | 2088 | self._first_record_creation_time = self._last_record_creation_time = -2 |
|
0 commit comments