[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

@@ -560,7 +560,9 @@ async def get_signed_url(
             if progress:
                 progress.advance(task_id=download_progress, task_type="Download")
 
-        transformation_results_enabled = "transformationresults" in await self.servicex.get_resources()
+        transformation_results_enabled = (
+            "transformationresults" in await self.servicex.get_resources()
+        )
 
         while True:
             if not cached_record:
@@ -581,7 +583,7 @@ async def get_signed_url(
                         if transformation_results_enabled:
                             if "file-path" not in file:
                                 continue
-                            file_path = file.get("file-path", '').replace("/", ":")
+                            file_path = file.get("file-path", "").replace("/", ":")
                         else:
                             file_path = file.filename
 

servicex/servicex_adapter.py

@@ -46,9 +46,12 @@
 
 from servicex.models import TransformRequest, TransformStatus, CachedDataset
 
-T = TypeVar('T')
+T = TypeVar("T")
 
-def requires_resource(resource_name: str) -> Callable[[Callable[..., T]], Callable[..., T]]:
+
+def requires_resource(
+    resource_name: str,
+) -> Callable[[Callable[..., T]], Callable[..., T]]:
     """
     Decorator to check if a specific API resource is available on the server before executing the method.
 
@@ -68,9 +71,10 @@ def decorator(func: Callable[..., T]) -> Callable[..., T]:
         func_name = func.__name__
 
         # Class-level cache for sync method resources
-        sync_cache_key = f'_sync_resources_for_{resource_name}'
+        sync_cache_key = f"_sync_resources_for_{resource_name}"
 
         if is_async:
+
             @wraps(func)
             async def async_wrapper(self, *args: Any, **kwargs: Any) -> T:
                 # Get resources and check availability in one operation
@@ -82,14 +86,15 @@ async def async_wrapper(self, *args: Any, **kwargs: Any) -> T:
 
             return cast(Callable[..., T], async_wrapper)
         else:
+
             @wraps(func)
             def sync_wrapper(self, *args: Any, **kwargs: Any) -> T:
                 # Initialize class-level cache attributes if needed
                 cls = self.__class__
                 if not hasattr(cls, sync_cache_key):
                     setattr(cls, sync_cache_key, (None, 0))  # (resources, timestamp)
 
-                cache_ttl = getattr(self, '_resources_cache_ttl', 300)
+                cache_ttl = getattr(self, "_resources_cache_ttl", 300)
                 cached_resources, timestamp = getattr(cls, sync_cache_key)
                 current_time = time.time()
 
@@ -117,8 +122,10 @@ def sync_wrapper(self, *args: Any, **kwargs: Any) -> T:
 
 class ResourceNotAvailableError(Exception):
     """Exception raised when a required resource is not available on the server."""
+
     pass
 
+
 class AuthorizationError(BaseException):
     pass
 
@@ -140,7 +147,7 @@ def __init__(self, url: str, refresh_token: Optional[str] = None):
 
         self._available_resources: Optional[Dict[str, Any]] = None
         self._resources_last_updated: Optional[float] = None
-        self._resources_cache_ttl = 60*5
+        self._resources_cache_ttl = 60 * 5
 
     async def get_resources(self) -> Dict[str, Any]:
         """
@@ -153,16 +160,18 @@ async def get_resources(self) -> Dict[str, Any]:
         current_time = time.time()
 
         # Return cached resources if they exist and are not expired
-        if (self._available_resources is not None and
-                self._resources_last_updated is not None and
-                current_time - self._resources_last_updated < self._resources_cache_ttl):
+        if (
+            self._available_resources is not None
+            and self._resources_last_updated is not None
+            and current_time - self._resources_last_updated < self._resources_cache_ttl
+        ):
             return self._available_resources
 
         # Fetch resources from server
         headers = await self._get_authorization()
         async with ClientSession() as session:
             async with session.get(
-                    headers=headers, url=f"{self.url}/servicex/resources"
+                headers=headers, url=f"{self.url}/servicex/resources"
             ) as r:
                 if r.status == 403:
                     raise AuthorizationError(