[pre-commit.ci] auto fixes from pre-commit.com hooks

for more information, see https://pre-commit.ci

Author: pre-commit-ci[bot]

servicex/query_core.py

@@ -558,13 +558,15 @@ async def get_signed_url(
             if self.minio:
                 # if self.minio exists, self.current_status will too
                 if self.current_status.files_completed > len(files_seen):
-                    files = await self.servicex.get_transformation_results(self.current_status.request_id)
+                    files = await self.servicex.get_transformation_results(
+                        self.current_status.request_id
+                    )
 
                     for file in files:
-                        if 'file-path' not in file:
+                        if "file-path" not in file:
                             continue
 
-                        file_path = file['file-path'].replace('/', ':')
+                        file_path = file["file-path"].replace("/", ":")
                         if file_path not in files_seen:
                             if signed_urls_only:
                                 download_tasks.append(

servicex/servicex_adapter.py

@@ -230,7 +230,7 @@ async def delete_transform(self, transform_id=None):
 
     async def get_transformation_results(self, request_id: str):
         headers = await self._get_authorization()
-        url = self.url + f'/servicex/internal/transformation/{request_id}/results'
+        url = self.url + f"/servicex/internal/transformation/{request_id}/results"
 
         async with ClientSession() as session:
             async with session.get(headers=headers, url=url) as r:
@@ -244,11 +244,9 @@ async def get_transformation_results(self, request_id: str):
 
                 if r.status != 200:
                     msg = await _extract_message(r)
-                    raise RuntimeError(
-                        f"Failed with message: {msg}"
-                    )
+                    raise RuntimeError(f"Failed with message: {msg}")
 
-                return (await r.json())['results']
+                return (await r.json())["results"]
 
     async def cancel_transform(self, transform_id=None):
         headers = await self._get_authorization()