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

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

pangeo_forge_recipes/openers.py

@@ -18,7 +18,7 @@ def open_url(
     cache: Optional[CacheFSSpecTarget] = None,
     secrets: Optional[Dict] = None,
     open_kwargs: Optional[Dict] = None,
-    fsspec_sync_patch: bool = False
+    fsspec_sync_patch: bool = False,
 ) -> OpenFileType:
     """Open a string-based URL with fsspec.
 
@@ -30,7 +30,7 @@ def open_url(
     kw = open_kwargs or {}
     if cache is not None:
         # this has side effects
-        cache.cache_file(url, secrets, fsspec_sync_patch **kw)
+        cache.cache_file(url, secrets, fsspec_sync_patch**kw)
         open_file = cache.open_file(url, mode="rb")
     else:
         open_file = _get_opener(url, secrets, fsspec_sync_patch, **kw)

pangeo_forge_recipes/storage.py

@@ -186,7 +186,9 @@ def _full_path(self, path: str) -> str:
 class CacheFSSpecTarget(FlatFSSpecTarget):
     """Alias for FlatFSSpecTarget"""
 
-    def cache_file(self, fname: str, secrets: Optional[dict], fsspec_sync_patch=False, **open_kwargs) -> None:
+    def cache_file(
+        self, fname: str, secrets: Optional[dict], fsspec_sync_patch=False, **open_kwargs
+    ) -> None:
         # check and see if the file already exists in the cache
         logger.info(f"Caching file '{fname}'")
         input_opener = _get_opener(fname, secrets, fsspec_sync_patch, **open_kwargs)
@@ -228,10 +230,13 @@ def _get_opener(fname, secrets, fsspec_sync_patch, **open_kwargs):
         logger.debug("Attempting to enable synchronous filesystem implementations in FSSpec")
         try:
             from httpfs_sync.core import SyncHTTPFileSystem
+
             SyncHTTPFileSystem.overwrite_async_registration()
             logger.debug("Synchronous HTTP implementation enabled.")
         except ImportError:
-            logger.warning("httpfs_sync could not be imported. Falling back to default (async) http implementation.")
+            logger.warning(
+                "httpfs_sync could not be imported. Falling back to default (async) http implementation."
+            )
 
     fname = fname if not secrets else _add_query_string_secrets(fname, secrets)
     return fsspec.open(fname, mode="rb", **open_kwargs)

pangeo_forge_recipes/transforms.py

@@ -156,7 +156,6 @@ class OpenURLWithFSSpec(beam.PTransform):
     max_concurrency: Optional[int] = None
     fsspec_sync_patch: bool = False
 
-
     def expand(self, pcoll):
         if isinstance(self.cache, str):
             cache = CacheFSSpecTarget.from_url(self.cache)
@@ -170,9 +169,7 @@ def expand(self, pcoll):
             open_kwargs=self.open_kwargs,
         )
         return pcoll | MapWithConcurrencyLimit(
-            open_url,
-            kwargs=kws,
-            max_concurrency=self.max_concurrency
+            open_url, kwargs=kws, max_concurrency=self.max_concurrency
         )