@@ -403,20 +403,14 @@ def revisions_fetcher():
403403 return self ._get_datasource_revisions (datasource_item )
404404
405405 datasource_item ._set_revisions (revisions_fetcher )
406- logger .info (
407- "Populated revisions for datasource (ID: {0})" .format (datasource_item .id )
408- )
406+ logger .info ("Populated revisions for datasource (ID: {0})" .format (datasource_item .id ))
409407
410408 def _get_datasource_revisions (
411- self ,
412- datasource_item : DatasourceItem ,
413- req_options : Optional ["RequestOptions" ] = None
409+ self , datasource_item : DatasourceItem , req_options : Optional ["RequestOptions" ] = None
414410 ) -> List [RevisionItem ]:
415411 url = "{0}/{1}/revisions" .format (self .baseurl , datasource_item .id )
416412 server_response = self .get_request (url , req_options )
417- revisions = RevisionItem .from_response (
418- server_response .content , self .parent_srv .namespace , datasource_item
419- )
413+ revisions = RevisionItem .from_response (server_response .content , self .parent_srv .namespace , datasource_item )
420414 return revisions
421415
422416 # Download 1 datasource revision by revision number
@@ -432,9 +426,7 @@ def download_revision(
432426 if not datasource_id :
433427 error = "Datasource ID undefined."
434428 raise ValueError (error )
435- url = "{0}/{1}/revisions/{2}/content" .format (
436- self .baseurl , datasource_id , revision_number
437- )
429+ url = "{0}/{1}/revisions/{2}/content" .format (self .baseurl , datasource_id , revision_number )
438430 if no_extract is False or no_extract is True :
439431 import warnings
440432
@@ -447,9 +439,7 @@ def download_revision(
447439 if not include_extract :
448440 url += "?includeExtract=False"
449441
450- with closing (
451- self .get_request (url , parameters = {"stream" : True })
452- ) as server_response :
442+ with closing (self .get_request (url , parameters = {"stream" : True })) as server_response :
453443 _ , params = cgi .parse_header (server_response .headers ["Content-Disposition" ])
454444 filename = to_filename (os .path .basename (params ["filename" ]))
455445
@@ -460,9 +450,7 @@ def download_revision(
460450 f .write (chunk )
461451
462452 logger .info (
463- "Downloaded datasource revision {0} to {1} (ID: {2})" .format (
464- revision_number , download_path , datasource_id
465- )
453+ "Downloaded datasource revision {0} to {1} (ID: {2})" .format (revision_number , download_path , datasource_id )
466454 )
467455 return os .path .abspath (download_path )
468456
@@ -473,5 +461,6 @@ def delete_revision(self, datasource_id: str, revision_number: str) -> None:
473461 url = "/" .join ([self .baseurl , datasource_id , "revisions" , revision_number ])
474462
475463 self .delete_request (url )
476- logger .info ("Deleted single datasource revsision (ID: {0}) (Revision: {1})" .format (datasource_id , revision_number ))
477-
464+ logger .info (
465+ "Deleted single datasource revsision (ID: {0}) (Revision: {1})" .format (datasource_id , revision_number )
466+ )
0 commit comments