@@ -442,9 +442,7 @@ def delete(self, url: str) -> Any:
442442 def put (self , url : str , body : Optional [dict ] = None ) -> Any :
443443 return self .send_request (url , method = 'PUT' , body = body )
444444
445- def send_request (
446- self , url : str , method : str , body : Optional [dict ] = None , query : Optional [dict ] = None
447- ) -> Any :
445+ def send_request (self , url : str , method : str , body : Optional [dict ] = None , query : Optional [dict ] = None ) -> Any :
448446 """
449447 Sends HTTP request to the SchemaRegistry, trying each base URL in turn.
450448
@@ -946,9 +944,7 @@ def lookup_schema(
946944
947945 query_string = '&' .join (f"{ key } ={ value } " for key , value in query_params .items ())
948946
949- response = self ._rest_client .post (
950- 'subjects/{}?{}' .format (_urlencode (subject_name ), query_string ), body = request
951- )
947+ response = self ._rest_client .post ('subjects/{}?{}' .format (_urlencode (subject_name ), query_string ), body = request )
952948
953949 result = RegisteredSchema .from_dict (response )
954950
@@ -1049,9 +1045,7 @@ def get_latest_version(self, subject_name: str, fmt: Optional[str] = None) -> 'R
10491045 return registered_schema
10501046
10511047 query = {'format' : fmt } if fmt is not None else None
1052- response = self ._rest_client .get (
1053- 'subjects/{}/versions/{}' .format (_urlencode (subject_name ), 'latest' ), query
1054- )
1048+ response = self ._rest_client .get ('subjects/{}/versions/{}' .format (_urlencode (subject_name ), 'latest' ), query )
10551049
10561050 registered_schema = RegisteredSchema .from_dict (response )
10571051
@@ -1131,9 +1125,7 @@ def get_version(
11311125 return registered_schema
11321126
11331127 query : dict [str , Any ] = {'deleted' : deleted , 'format' : fmt } if fmt is not None else {'deleted' : deleted }
1134- response = self ._rest_client .get (
1135- 'subjects/{}/versions/{}' .format (_urlencode (subject_name ), version ), query
1136- )
1128+ response = self ._rest_client .get ('subjects/{}/versions/{}' .format (_urlencode (subject_name ), version ), query )
11371129
11381130 registered_schema = RegisteredSchema .from_dict (response )
11391131
@@ -1220,9 +1212,7 @@ def delete_version(self, subject_name: str, version: int, permanent: bool = Fals
12201212 'subjects/{}/versions/{}?permanent=true' .format (_urlencode (subject_name ), version )
12211213 )
12221214 else :
1223- response = self ._rest_client .delete (
1224- 'subjects/{}/versions/{}' .format (_urlencode (subject_name ), version )
1225- )
1215+ response = self ._rest_client .delete ('subjects/{}/versions/{}' .format (_urlencode (subject_name ), version ))
12261216
12271217 # Clear cache for both soft and hard deletes to maintain consistency
12281218 self ._cache .remove_by_subject_version (subject_name , version )
@@ -1350,9 +1340,7 @@ def test_compatibility_all_versions(
13501340 )
13511341 return response ['is_compatible' ]
13521342
1353- def set_config (
1354- self , subject_name : Optional [str ] = None , config : Optional ['ServerConfig' ] = None
1355- ) -> 'ServerConfig' :
1343+ def set_config (self , subject_name : Optional [str ] = None , config : Optional ['ServerConfig' ] = None ) -> 'ServerConfig' :
13561344 """
13571345 Update global or subject config.
13581346
0 commit comments