[pre-commit.ci] pre-commit autoupdate

.github/workflows/ci.yml

@@ -39,7 +39,7 @@ jobs:
     strategy:
       fail-fast: false
       matrix:
-        python-version: ["3.8", "3.9", "3.10", "3.11", "3.12"]
+        python-version: ["3.9", "3.10", "3.11", "3.12"]
         runs-on: [ubuntu-latest]
     defaults:
       run:

.pre-commit-config.yaml

@@ -1,11 +1,11 @@
 repos:
   - repo: https://github.com/psf/black
-    rev: 24.4.0
+    rev: 24.10.0
     hooks:
       - id: black-jupyter
 
   - repo: https://github.com/pre-commit/pre-commit-hooks
-    rev: v4.6.0
+    rev: v5.0.0
     hooks:
       - id: check-added-large-files
       - id: check-case-conflict
@@ -37,7 +37,7 @@ repos:
         args: [--prose-wrap=always]
 
   - repo: https://github.com/asottile/blacken-docs
-    rev: 1.16.0
+    rev: 1.19.1
     hooks:
       - id: blacken-docs
         additional_dependencies: [black==22.3.0]
@@ -49,13 +49,13 @@ repos:
         args: ["-a", "from __future__ import annotations"] # Python 3.7+
 
   - repo: https://github.com/asottile/pyupgrade
-    rev: v3.15.2
+    rev: v3.19.0
     hooks:
       - id: pyupgrade
         args: ["--py37-plus"]
 
   - repo: https://github.com/asottile/setup-cfg-fmt
-    rev: v2.5.0
+    rev: v2.7.0
     hooks:
       - id: setup-cfg-fmt
 
@@ -77,21 +77,21 @@ repos:
           - flake8-print
 
   - repo: https://github.com/pycqa/flake8
-    rev: 7.0.0
+    rev: 7.1.1
     hooks:
       - id: flake8
         exclude: docs/conf.py
         additional_dependencies: *flake8_dependencies
 
   - repo: https://github.com/pre-commit/mirrors-mypy
-    rev: v1.9.0
+    rev: v1.13.0
     hooks:
       - id: mypy
         files: src
         args: []
 
   - repo: https://github.com/codespell-project/codespell
-    rev: v2.2.6
+    rev: v2.3.0
     hooks:
       - id: codespell
 
@@ -109,7 +109,7 @@ repos:
         exclude: .pre-commit-config.yaml
 
   - repo: https://github.com/mgedmin/check-manifest
-    rev: "0.49"
+    rev: "0.50"
     hooks:
       - id: check-manifest
         stages: [manual]

pyproject.toml

@@ -19,7 +19,7 @@ testpaths = [
 
 [tool.mypy]
 files = "src"
-python_version = "3.7"
+python_version = "3.9"
 warn_unused_configs = true
 strict = true
 show_error_codes = true

setup.cfg

@@ -32,7 +32,7 @@ project_urls =
 packages = find:
 install_requires =
     fsspec
-python_requires = >=3.8
+python_requires = >=3.9
 include_package_data = True
 package_dir =
     =src

src/fsspec_xrootd/xrootd.py

@@ -1,4 +1,4 @@
 from __future__ import annotations
 
 import asyncio
 import io
@@ -15,18 +15,18 @@
 from fsspec.asyn import AsyncFileSystem, _run_coros_in_chunks, sync, sync_wrapper
 from fsspec.exceptions import FSTimeoutError
 from fsspec.spec import AbstractBufferedFile
 from XRootD import client
 from XRootD.client.flags import (
     DirListFlags,
     MkDirFlags,
     OpenFlags,
     QueryCode,
     StatInfoFlags,
 )
 from XRootD.client.responses import HostList, XRootDStatus
 
 
 class ErrorCodes(IntEnum):
     INVALID_PATH = 400
 
 
@@ -51,13 +51,13 @@
         asyncio.get_running_loop().create_future()
     )
 
     def callback(status: XRootDStatus, content: T, servers: HostList) -> None:
         if future.cancelled():
             return
         loop = future.get_loop()
         try:
             loop.call_soon_threadsafe(future.set_result, (status, content))
         except Exception as exc:
             loop.call_soon_threadsafe(future.set_exception, exc)
 
     async def wrapped(*args: Any, **kwargs: Any) -> tuple[XRootDStatus, T]:
@@ -142,7 +142,7 @@
     handle: client.File
 
 
 class ReadonlyFileHandleCache:
     def __init__(self, loop: Any, max_items: int | None, ttl: int):
         self.loop = loop
         self._max_items = max_items
@@ -170,7 +170,7 @@
                 item.handle.close(callback=lambda *args: None)
         cache.clear()
 
     def close_all(self) -> None:
         self._close_all(self.loop, self._cache)
 
     async def _close(self, url: str, timeout: int) -> None:
@@ -183,7 +183,7 @@
     close = sync_wrapper(_close)
 
     async def _start_pruner(self) -> None:
         self._prune_task = asyncio.create_task(self._pruner())
 
     async def _pruner(self) -> None:
         while True:
@@ -220,7 +220,7 @@
         return handle
 
 
 class XRootDFileSystem(AsyncFileSystem):  # type: ignore[misc]
     protocol = "root"
     root_marker = "/"
     default_timeout = 60
@@ -911,26 +911,6 @@
             raise OSError(f"File did not read properly: {status.message}")
         return data
 
-    def flush(self, force: bool = False) -> None:
-        if self.closed:
-            raise ValueError("Flush on closed file")
-        if force and self.forced:
-            raise ValueError("Force flush cannot be called more than once")
-        if force:
-            self.forced = True
-
-        if self.mode not in {"wb", "ab"}:
-            # no-op to flush on read-mode
-            return
-
-        if not force and self.buffer.tell() < self.blocksize:
-            # Defer write on small block
-            return
-
-        if self._upload_chunk(final=force) is not False:
-            self.offset += self.buffer.seek(0, 2)
-            self.buffer = io.BytesIO()
-
     def _upload_chunk(self, final: bool = False) -> Any:
         status, _n = self._myFile.write(
             self.buffer.getvalue(),